Reactive Programming on Android with RxJava_468 x 60 copy 2.png

tarball.tar.gz

RxJava

Since its inception in 2012, RxJava has slowly gained in popularity for enabling reactive programming on Android. It is now deemed as the go-to and leading reactive library. Many companies have adopted the reactive way of programming, including Google, with its release of Android Architecture Components, which has many reactive elements in its design.

In this course, you will learn the fundamental principles of RxJava which will serve as a foundation for experienced Android developers who are new to the library and want to start integrating it into their apps.

Reactive Programming with RxJava

Which one of the following operators takes in a function and applies that function to all items in an `Observable`?

Which one of the following operators takes in a function and applies that function to all items in an <code>Observable</code>?

What is the output of the code given below?
```java
Observable<Integer> intStream = Observable.just(1, 2, 3);
intStream.skip(2)
 	.subscribe(val -> System.out.println(val) );
```

What is the output of the code given below?
<pre><code class="language-java">Observable&lt;Integer&gt; intStream = Observable.just(1, 2, 3);
intStream.skip(2)
 	.subscribe(val -&gt; System.out.println(val) );
</code></pre>

It waits for all emissions from a previous `Observable` to complete before continuing

It will interleave emissions if there is a delay

It will immediately subscribe to other emitted `Observable` objects if there is a delay

Which of the following is true for the `.concatMap()` operator?

Which of the following is true for the <code>.concatMap()</code> operator?

Which of the following operators can combine several `Observable` objects to create a single `Observable`?

Which of the following operators can combine several <code>Observable</code> objects to create a single <code>Observable</code>?

What is the output of the code given below?
```java
Observable<Integer> intStream = Observable.just(1, 2, 3, 4); 
 	intStream.reduce(
 		(i1, i2) -> i1 + i2 
	).subscribe(total -> {
 	System.out.println (total);
	});
```

What is the output of the code given below?
<pre><code class="language-java">Observable&lt;Integer&gt; intStream = Observable.just(1, 2, 3, 4); 
 	intStream.reduce(
 		(i1, i2) -&gt; i1 + i2 
	).subscribe(total -&gt; {
 	System.out.println (total);
	});
</code></pre>

Test your understanding of operators by completing this quiz.

Getting Started

Part 1: RxJava Basics

Reactive Programming

RxJava Core Components

Operators

Multithreading

Part 2: RxJava Advanced

Reactive Modeling on Android

Backpressure

Error Handling

Conclusion

Quiz