Hands-On Reactive Programming with Python

The zip operator

The zip operator combines items emitted by several observables, one by one. Each time all the source observables emit one item, then these items are combined as another item emitted on the output observable. The following figure shows the marble diagram of this operator:

Figure 9.15: The zip operator

This operator can be used both as a method or a static method. Its prototype is the following:

Observable.zip(self, *args)Observable.zip(cls, *args)

Here, several observables can be provided as args. The last parameter provided must be a function that combines the items of all the source observable items.

Here is an example of ...