Reactive Programming on Android with RxJava

Disposable and the Activity/Fragment Lifecycle
So far we have overlooked a key component in a reactive stream–the
Disposable
. A
Disposable
is returned as a result from a subscription so that we can control when to unsubscribe so that the
underlying
Observable
can stop emitting events. Failure to do so can cause unwanted memory leaks
that are hard to trace.
When dealing with the Activity/Fragment lifecycle, a good place to unsubscribe would be when the
Activity or Fragment is no longer needed. That is, in the
.onDestroy()
lifecycle.

---

Chapter 5: Reactive Modeling on Android
76
1
public class
MyActivity
extends
Activity
{
2
Disposable disposable
;
3
4
protected
void
onCreate
(
Bundle savedInstanceState
) {
5
this
.
disposable
=
// ...subscribe to some Observable
6
}
7
8
protected
void
onDestroy
() {
9
if
(!
disposable
.
isDisposed
()) {
10
disposable
.
dispose
();
11
}
12
}
13
}
RxJava also has classes that implement
DisposableContainer
, such as
CompositeDisposable
, to
make disposing from multiple
Disposable
instances easy.
1
public class
MyActivity
extends
Activity
{
2
CompositeDiposable disposables
=
new
CompositeDisposable
();
3
4
protected
void
onCreate
(
Bundle savedInstanceState
) {
5
Disposable disposable1
=
// ...subscribe to some Observable
6
Disposable disposable2
=
// ...subscribe to another Observable
7
disposables
.
addAll
(
disposable1
,
disposable2
);
8
}
9
10