What is the difference between flatmap and switchmap in RxJava?

by

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)

switchMap
in switchMap if the original observable emits something new, previous emissions no longer produce mapped observables; this is an effective way to avoid stale results

flatMap

in switchMap if the original observable emits something new, previous emissions no longer produce mapped observables; this is an effective way to avoi stale results

More Related Contents:

  1. Paginate Observable results without recursion – RxJava
  2. RxJava Fetching Observables In Parallel
  3. Combine a list of Observables and wait until all completed
  4. Hot and Cold observables: are there ‘hot’ and ‘cold’ operators?
  5. What is “callback hell” and how and why does RX solve it?
  6. Subject vs BehaviorSubject vs ReplaySubject in Angular
  7. When do you use map vs flatMap in RxJava?
  8. Rxjava Android how to use the Zip operator
  9. Shiny: what is the difference between observeEvent and eventReactive?
  10. Use cases for RxJava schedulers
  11. Dynamically creating tabs with plots in shiny without re-creating existing tabs
  12. rxjava: Can I use retry() but with delay?
  13. RxJava instead of AsyncTask?
  14. Spring 5 WebClient using ssl
  15. RxJava delay for each item of list emitted
  16. Chaining requests in Retrofit + RxJava
  17. block()/blockFirst()/blockLast() are blocking error when calling bodyToMono AFTER exchange()
  18. Retrofit and RxJava: How to combine two requests and get access to both results?
  19. What is the difference between Observable and a Subject in rxjs?
  20. Single Observable with Multiple Subscribers
  21. Android RxJava 2 JUnit test – getMainLooper in android.os.Looper not mocked RuntimeException
  22. How to customize SpringWebFlux WebClient JSON deserialization?
  23. Handle Paging with RxJava
  24. retrofit with rxjava handling network exceptions globally
  25. Can I use SpringMvc and webflux together?
  26. How to call back async function from Rx Subscribe?
  27. How does backpressure work in Project Reactor?
  28. How can I create an Observer over a dynamic list in RxJava?
  29. FormControl.detectchanges – why use distinctUntilChanged?
  30. Do we need to unsubscribe from observable that completes/errors-out?

Leave a Comment