I'm using an RxJava ReplaySubject in my Fragment.
I'm attempting to use the ReplaySubject in a way, where I would like the Subject to execute a process until completion (possibly beyond the life of the fragment).
On completion of the process, I would like to release the resources which -as i understand- is done by unsubscribing the subscription at the time of registering the observer (which in my case, is the subject itself).
In this github issue thread @benjchristensen says:
If it is an Observable then it should emit an onCompleted and be done.
If it is an Observer then it should unsubscribe from the Subscription it received when it called Observable.subscribe and it will give the Observable a chance to shutdown and clean up.
Subjects are a relatively thin layer on top of an Observable that allow you to feed
onError() calls from a source external to the Observable. Their unsubscribe behavior is the same as an Observable. If
onError() are called on the Subject, the subscribers will be unsubscribed. No need to call
unsubscribe() on the subscription returned from
ReplaySubject, note that resources will not be cleaned up until it is garbage collected. Even after
onCompleted() has been called on a
ReplaySubject, a subscriber can still subscribe and it will receive all of the original
onError() calls that were made previous to subscribing.