Reactive Programming on Android with RxJava

public
boolean
writeTextToFile
(
10
Context context
,
11
String filename
,
12
String text

---

Chapter 5: Reactive Modeling on Android
63
13
) {
14
FileOutputStream outputStream
;
15
try
{
16
outputStream
=
context
.
openFileOutput
(
17
filename
,
Context
.
MODE_PRIVATE
18
);
19
outputStream
.
write
(
text
.
getBytes
());
20
outputStream
.
close
();
21
return true
;
22
}
catch
(
Exception e
) {
23
e
.
printStackTrace
();
24
return false
;
25
}
26
}
When calling this function, we need to make sure that it is done off the main thread since this
operation may take a while depending on the text to be written. Imposing such restriction to the
caller adds mental load to the developer which increases the likelihood of bugs and it can potentially
slow down development. We can prevent such invocations on the main thread by perhaps adding
a comment to the function, implying that the method is synchronous in the method name, etc.
Although these changes are generally good practice, insuring that the method is called off the main
thread is still not guaranteed.
Using RxJava, we can easily wrap this into an
Observable
and specify the
Scheduler
that it should
run on. This way the caller doesn’t even need to be concerned about invoking the function in a
separate thread–the function will guarantee it.
1
/**
2
* Writes {@code text} to the filesystem.
3
*
4
* @param context a Context
5
* @param filename the name of the File
6
* @param text the String of text to write
7
* @return An Observable emitting a boolean indicating
8
*
whether or not the text was successfully written.
9
*/
10
public
Observable
<
Boolean
>
writeTextToFile
(
11
Context context
,
12
String filename
,
13
String text
14
) {
15
return
Observable
.
fromCallable
(() -> {
16
FileOutputStream outputStream
;

---

Chapter 5: Reactive Modeling on Android
64
17
outputStream
=
context
.
openFileOutput
(
18
filename
,
19
Context
.
MODE_PRIVATE
20
);
21
outputStream
.
write
(
text
.
getBytes
());
22
outputStream
.
close
();
23