Reactive Programming on Android with RxJava

Replacing Callbacks
So far, all the examples that we’ve looked at emit either one value (i.e. can be modeled as a
Single
),
or tell us if an operation succeeded or failed (i.e. can be modeled as a
Completable
).
How might we convert areas in our app that receive continuous updates or events (e.g. location
updates, view click events, sensor events, etc.)?
We will look at two ways to do this, first by using
.create()
, and then by using a new construct
called
Subject
s.
.create()
allows us to explicitly invoke any of the available methods of an
Observer
(i.e.
.onNext()
,
.onComplete()
or
.onError()
) as we receive updates from our data source. As we’ve seen, to use
.create()
, we pass in an
ObservableOnSubscribe
which receives an
ObservableEmitter
whenever
an
Observer
subscribes. Using the received emitter, we can then perform all the necessary set-up
calls to start receiving updates and then invoke the appropriate emitter event.
In the case of location updates, we can register to receive updates in
.create()
and emit location
updates as received.
1
public class
LocationManager
implements
2
GoogleApiClient
.
ConnectionCallbacks
,
3
GoogleApiClient
.
OnConnectionFailedListener
{
4
5
GoogleApiClient googleApiClient
;
6
7
LocationManager
(
Context context
) {
8
this
.
googleApiClient
=
new
GoogleApiClient
.
Builder
(
context
)
9
.
addConnectionCallbacks
(
this
)
10
.
addOnConnectionFailedListener
(
this
)
11
.
addApi
(
LocationServices
.
API
)
12
.
build
();
13
}
14
15
@Override