Summary

The source and the consumer are the backbones of RxJava. In this chapter, we discussed in depth about these backbones. Observable is the source of the data and Observer is a consumer. The Observable interface has many operators which enable the creation of the Observable. We discussed in depth about just(), empty(), never(), from(), throw() operators and also demonstrated their use. We not only created the Observable, but also discussed types of Observable such as Flowable, Single, and Maybe in depth. The enhanced version of Observer is Subscriber which supports handling of backpressure. DefaultSubscriber, DisposableSubscriber, ResourceSubscriber, and CompositeSubscriber are the types of Subscribers which we covered in our discussion. The Subject is a very interesting component which can act as both Observer as well as Observable. By taking examples, we discussed AsyncSubject...