Hands-On Reactive Programming with Python

The skip_until operator

The skip_until operator skips items emitted by a source observable until an item is emitted by another observable. The following figure shows the marble diagram of this operator:

Figure 9.31: The skip_until operator

Its prototype is the following:

Observable.skip_until(self, other)

Here, other is an observable being used to stop skipping items from the source observable.

Here is an example of the skip_until operator:

numbers = Subject()trigger = Subject()numbers.skip_until(trigger).subscribe(    on_next = lambda i: print("on_next {}".format(i)),    on_error = lambda e: print("on_error: {}".format(e)), on_completed = lambda: ...