Hands-On Reactive Programming with Python

The filter operator

The filter operator emits only the items of the input observable that match a predicate function. The following figure shows how this operator works:

Figure 6.5: The filter operator

The prototype of this operator is the following one:

Observable.filter(self, predicate)

The predicate argument is a function called for each item emitted on the input observable. If this predicate evaluates to true, then the item is emitted on the output observable. Otherwise, the item is dropped. The prototype of the predicate function is the following one:

predicate(item, index)

Here, item is the item to evaluate and index is the index of ...