tusharmath

const flatMapLatest = (fn, stream) => 
    stream.publish(s => s.flatMap(v => fn(v).takeUntil(s)));

const flatMapLatest = (fn, stream, resultSelector) => stream.publish(s => {
    return s.flatMap(v => fn(v).map(v2 => resultSelector(v, v2)).takeUntil(s));
});

const delay = (source, delay) => source.flatMap(e => Rx.Observable.timer(delay).mapTo(e))

const debounceTime = (time, stream) => flatMapLatest(v => of(v).delay(time), stream);