Daniel Arbuckle's Mastering Python

Combining and processing observable sequences

For combining and processing the observable sequences, we have three steps to follow. These are explained here:

• First, we merge the elephant and lion sequences into a single combined sequence, and process that sequence through our sometimes_loud function to create a new sequence we call louder, as shown in the following code example:

      louder = rx.Observable.merge(elephant,      lion).select(sometimes_loud) 

The select method used in that line is the direct equivalent of the map function in a functional programming environment.

• Next, we merge the louder sequence with the remaining animal sequences and tell the system that whenever a new value arrives at the front of that merge sequence, it should ...