Reactive Programming on Android with RxJava

public class
NetworkClient
{
2
Observable
<
Bitmap
>
fetchImage
(
String filename
) {
3
// Network call to fetch image here
4
}
5
}
6
7
public class
ImageStore
{
8
9
private
NetworkClient networkClient
;
10
private
ImageStoreCache cache
=
new
ImageStoreCache
();
11
12
public
ImageStore
(
NetworkClient networkClient
) {
13
this
.
networkClient
=
networkClient
;
14
}
15
16
public
Observable
<
Bitmap
>
getImage
(
String filename
) {
17
return
cache
.
getImage
(
filename
)
18
.
onErrorResumeNext
(
19
networkClient
.
fetchImage
(
20
filename
21
).
doOnNext
(
bitmap
->
cache
.
addImage
(
filename
,
bitmap
))
22
);
23
}
24
}
When an error is received from the cache, we retrieve an image over the network via
.fetchImage()
.
Finally, once the image is retrieved over the network, the cache is then updated to store the retrieved
bitmap.
Retry Operators
There are some operations that if they fail to complete require retrying either immediately or at
a later point in time. Say for example we are developing a chat application and a user sends a
message to another user. If sending that message fails because of a bad network connection, that
message should get resent at a better point in time (e.g. when the sender establishes a better network
connection). While there are many ways to solve this problem, a simple solution would be to add
retry logic until the operation succeeds.

---

Chapter 7: Error Handling
98
1