Todo List Tutorial
Search…
Operators
Here we will walk you through some basic operators. Each one will have link to RxMarbles: Interactive diagrams of Rx Observables example and from RxJS and Reactive Programming - Animations and visual lessons​

map

map is an operator which is mapping emitted values to ones we want - it takes value, passes it through given function and returns new Observable.
​Map on RxMarbles​
You may think of map as of a mist which each boat makes a blue boat - it is mapping boat :speedboat: to blue boat.

filter

filter is an operator which emits only those values which satisfy a specified predicate.
This operator may be one that will allow only yellow boats to pass the bridge, or only those who has at least 3 people on board.

merge

merge flattens multiple Observables together by returning mix of their values into one Observable.
merge may be understood as a place where two rivers join and make one new river. Boats from both of them will flow on the new river with the order they've entered the river crossing.

combineLatest

combineLatest multiple Observables to create an Observable whose values are calculated from the latest values of each of its input Observables.
You may think of combineLatest as of gallery showing a pair of boats (from different rivers), always the latest ones that entered joined river.

takeLast

takeLast emits last x values emitted by the source Observable. Which means that if you will call takeLast(3) it will emit last 3 values emitted by Observable. It will do so after Observable reaching completed state.

take

take emits first x values emitted by the source Observable. Which means that if you will call take(3) it will emit first 3 values emitted by Observable. After that it will complete returned Observable.
Copy link
On this page
map
filter
merge
combineLatest
takeLast
take