The rxjava doc definition of switchmap is rather vague and it links to the same page as flatmap. What is the difference between the two operators?
-
1About it links to the same page as flatmap. It is really true. But scroll down to the Language-Specific Information section and open interesting operator. I think this should be done automatically from TOC, but... Also you can see the same picture in javadoc.– Ruslan StelmachenkoMay 8, 2016 at 11:03
7 Answers
According to the documentation ( http://reactivex.io/documentation/operators/flatmap.html )
the switchMap
is like the flatMap
, but it will only emit items from the new observable until a new event is emitted from the source observable.
The marble diagram shows it well. Notice the difference in the diagrams:
In switchMap
the second original emission (green marble) does not emit its second mapped emission (green square), since the third original emission (blue marble) has begun and already emitted its first mapped emission (blue diamond). In other words, only the first of two mapped green emissions happens; no green square is emitted because the blue diamond beat it.
In flatMap
, all mapped results will be emitted, even if they're "stale". In other words, both first and second of the mapped green emissions happen -- a green square would've been emitted (if they used consistent map function; since they did not, you see the second green diamond, even though it is emitted after the first blue diamond)
flatMap
-
4Thanks, the diagram is very helpful. Do you know a real world example where switchMap would be used? Jan 28, 2015 at 8:45
-
2@JulianGo there's an example here: github.com/samuelgruetter/rx-playground/blob/master/… It uses
.map(func).switch
, but that's the same as.switchMap(func)
. Jan 28, 2015 at 12:26 -
2Just in case someone still need a real world example of switchMap, he can follow this link link and it will understand when to use swicthMap instead of flatMap. Nov 28, 2016 at 12:35
-
2For an example using SwitchMap from Ben Lesh using RxJs5 - see minutes 25-26 here - youtube.com/watch?v=3LKMwkuK0ZE for me, flatmap was already understood... Jan 16, 2017 at 16:36
-
12The marble diagram shows it well? What? I guess if you already understand switchmap maybe. Jan 29, 2017 at 21:49
I came across this when implementing "instant search" - i.e. when user types in a text box, and results appear in near real-time with each key stroke. The solution seems to be:
- Have a subject, such as PublishSubject of String
- In the text box change callback, invoke .onNext(text)
- apply .debounce filter to rate limit server queries
- apply .switchMap to perform a server query - taking search term and returning Observable of SearchResponse
- apply .subscribe with a method that consumes SearchResponse and updates the UI.
With flatMap, the search results could be stale, because search responses may come back out of order. To fix this, switchMap should be used, since it ensures that an old observable is unsubscribed once a newer one is provided.
So, in summary, flatMap should be used when all results matter, regardless of their timing, and switchMap should be used when only results from the last Observable matter.
No flatMap discussion is complete without comparing and contrasting with switchMap
, concatMap
and concatMapEager
.
All of these methods take a Func1
that transform the stream into Observable
s which are then emitted; the difference is when the returned Observable
s are subscribed and unsubscribed to, and if and when those the emissions of those Observable
s are emitted by the ____Map
operator in question.
flatMap
subscribes to as many emittedObservable
s as possible. (It is a platform dependant number. e.g. a lower number on Android) Use this when order is NOT important, and you want emissions ASAP.concatMap
subscribes to the firstObservable
and only subscribes to the nextObservable
when the previous one has completed. Use this when order is important and you want to conserve resources. A perfect example is deferring a network call by checking the cache first. That may typically be followed by a.first()
or.takeFirst()
to avoid doing unnecessary work.http://blog.danlew.net/2015/06/22/loading-data-from-multiple-sources-with-rxjava/
concatMapEager
works much the same but subscribes to as many as possible (platform dependant) but will only emit once the previousObservable
has completed. Perfect when you have a lot of parallel-processing that needs to be done, but (unlike flatMap) you want to maintain the original order.switchMap
will subscribe to the lastObservable
it encounters and unsubscribe from all previousObservable
s. This is perfect for cases like search-suggestions: once a user has changed their search query, the old request is no longer of any interest, so it is unsubscribed, and a well behaved Api end-point will cancel the network request.
If you are returning Observable
s that don't subscribeOn
another thread, all of the above methods may behave much the same. The interesting, and useful behaviour emerges when you allow the nested Observable
s to act on their own threads. Then you can get get a lot of benefits from parallel processing, and intelligently unsubscribing or not subscribing from Observable
s that don't interest your Subscriber
s
amb
may also be of interest. Given any number ofObservable
s it emits the same items that the firstObservable
to emit anything emits. That could be useful when you have multiple sources that could/should return the same thing and you want performance. e.g. sorting, you mightamb
a quick-sort with a merge-sort and use whichever was faster.
-
2
If you are returning Observables that don't subscribeOn another thread, all of the above methods may behave much the same.
- every explanation ofswitchMap vs flatMap
I encountered before, missed this important aspect, now everything is clearer. Thank you.– Andy ResAug 4, 2019 at 8:30
switchMap was once called flatMapLatest in RxJS 4.
It basically just passes on the events from the latest Observable and unsubscribes from the previous one.
-
@EpicPandaForce Although it is inconsistent with combineLatest, which emits the latest values whenever a source observable emits (not emits once). Dec 10, 2016 at 16:50
-
2Partly the reason it's called switchMap is because you can implement this operator yourself by using o.map(...).switch(). Though then I would imagine it'd be mapSwitch, which doesn't seem to roll off the tongue so easily. Apr 19, 2017 at 3:11
Map, FlatMap, ConcatMap and SwitchMap applies a function or modifies the data emitted by an Observable.
Map modifies each item emitted by a source Observable and emits the modified item.
FlatMap, SwitchMap and ConcatMap also applies a function on each emitted item but instead of returning the modified item, it returns the Observable itself which can emit data again.
FlatMap and ConcatMap work is pretty much same. They merge items emitted by multiple Observables and returns a single Observable.
- The difference between FlatMap and ConcatMap is the order in which the items are emitted.
- FlatMap can interleave items while emitting i.e the emitted items order is not maintained.
- ConcatMap preserves the order of items. But the main disadvantage of ConcatMap is, it has to wait for each Observable to complete its work thus asynchronous is not maintained.
- SwitchMap is a bit different from FlatMap and ConcatMap. SwitchMap unsubscribes from the previous source Observable whenever new item started emitting, thus always emitting the items from current Observable.
If you´re looking for an example code
/**
* We switch from original item to a new observable just using switchMap.
* It´s a way to replace the Observable instead just the item as map does
* Emitted:Person{name='Pablo', age=0, sex='no_sex'}
*/
@Test
public void testSwitchMap() {
Observable.just(new Person("Pablo", 34, "male"))
.switchMap(person -> Observable.just(new Person("Pablo", 0, "no_sex")))
.subscribe(System.out::println);
}
You can see more examples here https://github.com/politrons/reactive
-
4But you miss the key feature of switchMap that distinguishes it from flatMap - only the most recent Observable matters, while unsubscribing from the previous ones. Aug 21, 2016 at 23:43
-
3In this example, when you replace
switchMap
withflatMap
it will work exactly the same. Jul 18, 2018 at 14:02
Here is the one more - 101 line long example. That explains the thing for me.
Like was said: it gets the last observable (the slowest one if you will) and ignores the rest.
As a result:
Time | scheduler | state
----------------------------
0 | main | Starting
84 | main | Created
103 | main | Subscribed
118 | Sched-C-0 | Going to emmit: A
119 | Sched-C-1 | Going to emmit: B
119 | Sched-C-0 | Sleep for 1 seconds for A
119 | Sched-C-1 | Sleep for 2 seconds for B
1123 | Sched-C-0 | Emitted (A) in 1000 milliseconds
2122 | Sched-C-1 | Emitted (B) in 2000 milliseconds
2128 | Sched-C-1 | Got B processed
2128 | Sched-C-1 | Completed
You see the A got ignored.