filter map function for Rx.Observable.

filter_map.ts

import {Option} from 'option-t';
import {Observable} from 'rx';

type FilterMapFn<T, U> = (v: T) => Option<U>;

function filterMapForObservable<T, U>(source: Observable<T>, op: FilterMapFn<T, U>): Observable<U> {
    const filtered = source.flatMap(function(v: T): Observable<U> {
        const mapped: Option<U> = op(v);
        const result: Observable<U> =
            mapped.mapOrElse(function def(): Observable<U> {
              return Observable.never<U>();
            }, function map(v: U): Observable<U> {
              return Observable.return<U>(v);
            });
        return result;
    });
    return filtered;
}