February 2018
Intermediate to advanced
552 pages
13h 46m
English
In the preceding example, we have explored all three RxScala components—Observable, Subscription, and Observer—very well. I hope that you now have a clear idea about how these three components interact with each other to perform asynchronous data stream processing.
One point to note about Observer is that it does not support Subscription and back-pressure handling methods. We should use Subscriber for this purpose.
Subscriber extends the Observer with the following two new features:
Now it's time to explore backpressure with the same example. We will use the same project and create a new Scala app for this purpose.
Perform the following steps to develop ...
Read now
Unlock full access