Summary

In this chapter, we have explored parts of the RxJS library and the fundamental concept of Observables that it provides. 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.

We have only just scratched the surface of the functionality available in the RxJS library, however, but have covered some of the main topics and concepts. Feel free to head over to the RxJS website to view the wealth of available operators and functions that...