|
| 1 | +# Examples of Operators |
| 2 | + |
| 3 | +Here we will walk you through some basic operators. Each one will have link to [RxMarbles: Interactive diagrams of Rx Observables](https://rxmarbles.com/) example and from [RxJS and Reactive Programming - Animations and visual lessons](https://reactive.how/) |
| 4 | + |
| 5 | +## map |
| 6 | + |
| 7 | +`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. |
| 8 | + |
| 9 | +> [Map on RxMarbles](https://rxmarbles.com/#map) |
| 10 | +> |
| 11 | +> [Map on reactive.how](https://reactive.how/map) |
| 12 | +
|
| 13 | +You may think of `map` as of a mist which each boat makes a blue boat - it is mapping boat :speedboat: to blue boat. |
| 14 | + |
| 15 | +## filter |
| 16 | + |
| 17 | +`filter` is an operator which emits only those values which satisfy a specified predicate. |
| 18 | + |
| 19 | +> [filter on RxMarbles](https://rxmarbles.com/#filter) |
| 20 | +> |
| 21 | +> [Map vs Filter on reactive.how](https://reactive.how/filter) |
| 22 | +
|
| 23 | +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. |
| 24 | + |
| 25 | +## merge |
| 26 | + |
| 27 | +`merge` flattens multiple Observables together by returning mix of their values into one Observable. |
| 28 | + |
| 29 | +> [merge on RxMarbles](https://rxmarbles.com/#merge) |
| 30 | +> |
| 31 | +> [merge on reactive.how](https://reactive.how/merge) |
| 32 | +
|
| 33 | +`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. |
| 34 | + |
| 35 | +## combineLatest |
| 36 | + |
| 37 | +`combineLatest` multiple Observables to create an Observable whose values are calculated from the latest values of each of its input Observables. |
| 38 | + |
| 39 | +> [combineLatest on RxMarbles](https://rxmarbles.com/#combineLatest) |
| 40 | +> |
| 41 | +> [combineLatest on reactive.how](https://reactive.how/combinelatest) |
| 42 | +
|
| 43 | +You may think of `combineLatest` as of gallery showing a pair of boats (from different rivers), always the latest ones that entered joined river. |
| 44 | + |
| 45 | +## takeLast |
| 46 | + |
| 47 | +`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. |
| 48 | + |
| 49 | +> [takeLast on RxMarbles](https://rxmarbles.com/#takeLast) |
| 50 | +> |
| 51 | +> [takeLast on reactive.how](https://reactive.how/takelast) |
| 52 | +
|
| 53 | +## take |
| 54 | + |
| 55 | +`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. |
| 56 | + |
| 57 | +> [take on RxMarbles](https://rxmarbles.com/#take) |
| 58 | +> |
| 59 | +> [take on reactive.how](https://reactive.how/take) |
0 commit comments