Chapter 10. Using Advanced Operators and Techniques in RxPHP

This is the last chapter dedicated to explaining new RxPHP operators. There are few topics that didn't fit into any of the preceding chapters, so we'll cover them now. A couple of times we'll revisit Observable multicasting from Chapter 8 , Multicasting in RxPHP and PHP7 pthreads Extension, in practical examples and also four new operators, zip(), window(), materialize(), and dematerialize(), which are more advanced techniques for modifying Observable chains.

In particular, in this chapter we'll cover the following topics:

• The zip() and window() operators that work with higher-order Observables

• The materialize() and dematerialize() operators

• Error propagation in Observable chains and how to properly catch exceptions from user-defined callbacks

• Theory around creating hot/cold Observables and the difference in unsubscribing and completing Observable chains

• Creating anonymous operators

• Writing a recursive DirectoryIteratorObservable that...