Summary

In this chapter, we have explored parts of the RxJS library and the fundamental concept of Observables that it provides.

We can distill the key takeaways from this chapter into the following:

• We have seen how we can create Observables easily using the of and from functions, as well as how we can transform values emitted from an Observable stream using the pipe, map, take, toArray, mergeMap, and contactMap functions.

• We also explored error handling through the error function available on a subscription, and how to handle errors within an Observable stream using the catchError function.

• We then explored how to wait for multiple Observable streams to complete with the forkJoin function and rounded out the chapter with a discussion on Subjects and an implementation of a simple event bus.