bufferTime - 2

RxJS 5 bufferTime

HTML

<script src="https://npmcdn.com/@reactivex/rxjs@5.0.0-beta.8/dist/global/Rx.umd.js"></script>

JavaScript

const buffered$ = new Rx.Subject().bufferTime(2000);


const firstV$ = new Rx.Subject().take(1)
const bufferedSkip$ = buffered$.skip(1)
const merged = Rx.Observable.merge(bufferedSkip$, firstV$)


//Print values to console
const msub = merged.subscribe(v => console.warn('Let it go', v))

console.warn(merged)

merged.next(1)
merged.next(1)
merged.next(1)