Rx.Observable.of(4,5,6,7,8) (45678|)
Rx.Observable.interval(500).take(4) ---0---1---2---3|
netflix reactive extensions