Chapter 9. Partitioning and combining observables
This chapter covers
- Partitioning observables into groups of related notifications
- Emitting chunks of notifications by sliding windows and buffers
- Combining multiple observables into one
- Reacting to patterns of coincidence
A typical application is usually composed of multiple workflows that structure its behavior. In many cases, the application needs to handle and react to more than one data source, UI events, push notifications, remote procedure calls, and so on. Suppose your application needs to consume messages from various sources (such as social networking) and react to all of them in the same way. Or, say your application deals with a source that emits a stream of various kinds of ...