Reactive Programming on Android with RxJava

Marble diagram of .concat()
Zip
.zip()
enables pair-wise
zipping
of emissions from multiple different
Observable
s. It works by
combining the emission from each
Observable
using the specified combiner function. This is
especially handy when you have two data sources of different types that you would like to combine
into a single
Observable
source.

---

Chapter 3: Operators
37
Marble diagram of .zip()
Each zipped item is emitted in a strict sequence: the result of the 1st zipped item is the combination of
the 1st item in each stream, the 2nd zipped item is the combination of the 2nd item in each stream,
and so on. This implies that the zipped
Observable
will emit the same number of items emitted
by the
Observable
that has the fewest items; if one sequence does not emit any items, the zipped
Observable
will also not emit any items.
The size of
.zip()
’s output sequence is the same size as the source
Observable
with the
smallest sequence. If one
Observable
does not emit any items, the zipped
Observable
will also not emit any items.
Say for example we wanted to make 2 separate network calls to populate a user’s profile view. One
network call to retrieve a user’s detail information and another to get all the places they have been
before:
1
Observable
<
UserDetail
>
getUserDetail
(
User user
) {
2
// Make network call to get `user`'s detailed information
3
}
4
5
Observable
<
List
<
Place
>>
getVisitedPlaces
(
User user
) {
6
// Make network call to get all the places `user` has visited.
7
}
Using
.zip()
followed by combining the result into a