Chaining Observables in RxJS

by

About promise composition vs. Rxjs, as this is a frequently asked question, you can refer to a number of previously asked questions on SO, among which :

Basically, flatMap is the equivalent of Promise.then.

For your second question, do you want to replay values already emitted, or do you want to process new values as they arrive? In the first case, check the publishReplay operator. In the second case, standard subscription is enough. However you might need to be aware of the cold. vs. hot dichotomy depending on your source (cf. Hot and Cold observables : are there ‘hot’ and ‘cold’ operators? for an illustrated explanation of the concept)

More Related Contents:

  1. Hot and Cold observables: are there ‘hot’ and ‘cold’ operators?
  2. What is “callback hell” and how and why does RX solve it?
  3. What are the semantics of different RxJS subjects?
  4. Subject vs BehaviorSubject vs ReplaySubject in Angular
  5. How to achieve a debounce service on input keyup event in angular2 with rxjs
  6. What is the difference between Observable and a Subject in rxjs?
  7. How to ‘wait’ for two observables in RxJS
  8. Observable Finally on Subscribe
  9. Is it bad practice to have a constructor function return a Promise?
  10. Resolve promises one after another (i.e. in sequence)?
  11. async/await always returns promise
  12. Building a promise chain recursively in javascript – memory considerations
  13. Asynchronous exception handling with bluebird promises
  14. Return from a promise then()
  15. How to sequentially run promises with Q in Javascript?
  16. Promise All with Axios
  17. How to know when all Promises are Resolved in a dynamic “iterable” parameter?
  18. How to do the chain sequence in rxjs
  19. using async await and .then together
  20. While loop using bluebird promises
  21. Javascript – how to control how many promises access network in parallel
  22. Why does the Promise constructor require a function that calls ‘resolve’ when complete, but ‘then’ does not – it returns a value instead?
  23. Promises: Repeat operation until it succeeds?
  24. Ember transition & rendering complete event
  25. Understanding JS Promises
  26. Typescript Promise rejection type
  27. Difference of using async / await vs promises?
  28. Promise.all().then() resolve?
  29. JavaScript asynchronous programming: promises vs generators
  30. How can I Interleave / merge async iterables?

Leave a Comment