This section is a continuation of the Marble diagrams section of Chapter 1, Getting Started with Reactive and Functional Programming. Refer to that section to understand what a Marble diagram is and its rules and benefits.
In this section, we will discuss the following things:
- How to represent Marble diagrams for RxScala components
- How to represent Marble diagrams for RxScala basic operations
The following diagram shows what our RxScala application's input Observable looks like:
An input Observable (that is, a data stream) is represented, as shown in the following diagram; when the Observable ( the input data stream) emits the data elements, its associated Observer's onNext() function is executed to take data elements one by one to apply the data transformation:
An Observer that is completed successfully is represented as follows. In the...
