RxJS Rx.ReplaySubject

HTML

<script src="https://rawgit.com/Reactive-Extensions/RxJS/master/dist/rx.all.js"></script>

JavaScript

// https://github.com/Reactive-Extensions/RxJS/issues/1085
//const subject = new Rx.ReplaySubject(1)
const subject = new Rx.AsyncSubject()
const even = subject.filter(x => x % 2 === 0)
const odd = subject.filter(x => x % 2 === 1)

subject.onNext(101)
subject.onNext(102)
subject.onNext(103)
subject.onNext(104)
subject.onNext(105)

//even.subscribe(x => console.log('even', x))
//odd.subscribe(x => console.log('odd', x))
//subject.isEmpty().subscribe(x => console.log(x))
//subject.skip(1).take(1).subscribe(x => console.log(x))
subject.take(1).subscribe(x => console.log(x))
subject.next(106)
//subject.complete()