If I have an array, and I want to apply filter, map, forEach to it.
let Observable = Rx.Observable; let ary = Observable.fromArray([1,2,5,4,6]); ary .filter((item) => item % 2===1) .map((item)=> item + "!") .forEach((item) => console.log(item)); /* "1!" "5!" */
The same opreations filter, map, foreach can also handler async data which arrive over time:
let Observable = Rx.Observable; let ary = Observable.interval(500).take(8); ary .filter((item) => item % 2===1) .map((item)=> item + "!") .forEach((item) => console.log(item)); /** "1!" "3!" "5!" "7!" */
[rxjs] Async, handle data over time
原文：http://www.cnblogs.com/Answer1215/p/4743529.html