Summary
First-class event streams are an extremely expressive tool for modelling dynamic, event-based systems with time-varying values. Rx Observable objects are an event stream implementation designed to build scalable, concurrent, event-based applications. In this chapter, we saw how to create Rx Observable objects and how to subscribe to their events. We studied the Observable contract and learned how to compose complex Observable objects from simple ones. We investigated various ways of recovering from failures and saw how to use Rx schedulers to transfer events between threads. Finally, we learned how to design loosely coupled systems with Rx subjects. These powerful tools together allow us to build a plethora of different applications, ranging ...
Become an O’Reilly member and get unlimited access to this title plus top books and audiobooks from O’Reilly and nearly 200 top publishers, thousands of courses curated by job role, 150+ live events each month,
and much more.
Read now
Unlock full access