This is a continuation post in a 3 part series:
This was the part that I initially found most tricky to grasp but also most important to know as an AndroidDev (memory leak and all).
Jedi master Karnok explains this best in the wiki:
In RxJava 1.x, the interface rx.Subscription was responsible for stream and resource lifecycle management, namely unsubscribing a sequence and releasing general resources such as scheduled tasks. The Reactive-Streams specification took this name for specifying an interaction point between a source and a consumer: org.reactivestreams.Subscription allows requesting a positive amount from the upstream and allows cancelling the sequence.
From that definition alone, it would appear like nothing’s changed but that is definitely not the case. In my first post, I pointed out:
The use of => vs = was intentional. If you look at the source code for
Publisher’s subscribe method again, you’ll notice a return type of
void viz. it doesn’t return a Subscription for you to tack on to a CompositeSubscription (which you can then conveniently dispose of onStop/onDestroy).
Because Reactive-Streams base interface, org.reactivestreams.Publisher defines the subscribe() method as void, Flowable.subscribe(Subscriber) no longer returns any Subscription (or Disposable). The other base reactive types also follow this signature with their respective subscriber types.
So if you look at the declarations again
Notice the return type
void in all of them.
Getting hold of Subscriptions
So you may ask how do I get a hold off that Subscription then (so that you might rightly cancel or dispose it off like a responsible citizen)?
Let’s take a look at the the
Subscriber’s onSubscribe method:
You are now given the Subscription class as a parameter in your
onSubscribe callback. So within the OnSubscribe method, you have a hold of the subscription and can then conveniently dispose of the Subscription inside the
This was actually a pretty well thought off change because this really makes the interface for a Subscriber lightweight. In RxJava 1 land, Subscribers were more “heavy” cause they had to deal with a lot of the internal state handling.
… but who are we kidding: that is not convenient at all (atleast for those of us who need the subscriber to depend on our lifecycle). I’d rather just shove everything into a CompositeSubscription like before and be on my merry way. But such are the rulings of the Reactive Streams spec.
Thankfully the maintainers of RxJava in all their benevolence realized this trade-off and have remedied this with convenient helpers.
But first, some more definitions:
Disposable is the new
What we called
Subscription in RxJava 1 is now called
Why couldn’t we just keep the name
Subscription? (per my understanding):
- You have to remember the Reactive Streams spec already has this name reserved and the maintainers of RxJava 2 are serious about the spec adherence. We don’t want confusion about there being more functionality with an Rx Subscription vs other Reactive Stream spec adhering libraries
- We still want some of the behaviors and conveniences of RxJava 1 like CompositeSubscriptions.
So if Disposables is what we’re using now, by that token we have a CompositeDisposable which is the object you want to be using and tacking all your Disposables onto. It functions pretty similarly to how we used CompositeSubscription before.
Ok, back to the original question: how do I get a hold of the Disposable?
Getting hold of Disposables
Now before we go any further, if you’re adding your callbacks directly in the form of lambdas, this is not a problem as most observable sources return a Disposable with their subscribe method call when not provided with a subscriber object:
So if you look at some sample code, the below works fine no problem:
However if I rewrote that code just a little differently:
The above code won’t compile. If you want to pass a Subscriber object (like the above
ObservableSource or an
Observer) then this strategy won’t work.
A lot of existing RxJava 1 code uses this strategy a lot, so the RxJava maintainers very kindly added a handy method on most Publishers called
subscribeWith. From the wiki:
Due to the Reactive-Streams specification, Publisher.subscribe returns void and the pattern by itself no longer works in 2.0. To remedy this, the method E subscribeWith(E subscriber) has been added to each base reactive class which returns its input subscriber/observer as is.
If you’re still following closely, you’d ask… wait! that doesn’t return a Disposable! why the hell is this even remotely more convenient?
Well… it says that the
Subscriber you pass is sent back to you with
subscribeWith. But what if your Subscriber itself “implemented” the Disposable interface? If you had a DisposableSubscriber, you could for all practical purposes treat it as a disposable and tack it on to a CompositeDisposable, while still using it as a Subscriber. That’s typically the pattern you want to adopt. Here’s some code that should make these techniques clear:
DisposableSubscriber, there’s also a
ResourceSubscriber which implements Disposable. There’s also a
DefaultSubscriber which doesn’t implement the Disposable interface, so you can’t use it with
subscribeWith (you could use it but you wouldn’t get anything “disposable” out of it).
It seems like both DisposableSubscriber and ResourceSubscriber do the same thing. Why do both of these exist you ask?
The original 1.x Subscriber had the ability to take Subscriptions which allowed “disposing” the additional resources that particular Subscriber needed when the lifecycle ended or the Subscriber got unsubscribed. Since 2.x Subscriber is an interface declared externally, the old functionality had to be implemented via a separate abstract class: “ResourceSubscriber”. A key difference is you can create and associate Disposable resources with it and dispose them together from within the onError() and onComplete() methods you implement. Have a look at the example from within the docs
to .clear or to .dispose
There’s no longer an
unsubscribe call on CompositeDisposable. It’s been renamed to
dispose ☝️️ but you don’t want to be using either of those anyway. The
clear method remains, and is most likely the method you want to use.
What’s the difference?
unsubscribe/dispose terminates even future subscriptions while clear doesn’t allowing you to reuse the CompositeDisposable.
In the next and final part, we’ll look at some of the miscellaneous changes.
My thanks to Donn Felker & David Karnok for reviewing this post. Special thanks to David for correcting some of my misconceptions.