Summary

This chapter was really code intensive, with a lot of examples based on using Unix sockets and WebSockets. We also utilized a lot of what we've learned in this and the previous chapter, including higher-order Observables, with swtichLatest() and combineLatest(), backpressure and which operators we can use, using event loops with multiple streams, and using the multicast() operator to share a single subscription among multiple observers.

In the next chapter, we'll have a look at multicasting in Rx and start using the pthreads PHP extension to leverage true parallelism with threads that would normally be hardly achievable.