Daniel Arbuckle's Mastering Python

Translating our zoo demo into Rx

Like our example in the previous section, Rx provides Observer and Observable classes, and they encompass the same basic functionality.

The largest visible difference is that the Observable class of Rx has a large number of factory methods that could be used to construct special-purpose observables, especially, observables that produce a sequence based on one or more other observable sequences. In other words, most of the operators and operations that we'll use to construct a reactive dataflow are methods of the Observable class.

Let's take a moment to rewrite our demo from the previous section in Rx and we'll see what that means in practice.

The AnimalEvent class can stay the same, since it's just a data ...