Hands-On Reactive Programming with Python

The combine_latest operator

The combine_latest operator allows you to emit items that are composed from the latest value of the items emitted by each source observable. Here is the marble diagram of this operator:

Figure 8.6: The combine_latest operator

This operator can be used as a class method or as a member method:

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

The args argument contains all the source observables that must be combined. A list can also be provided instead of several arguments. The last argument must be a function that implements the combination logic. This function takes as many input arguments ...