Hands-On Reactive Programming with Python

The take operator

The take operator emits only the first items of the source observable. This operator is the complementary operator of the skip operator that behaves the opposite way. The following is its marble diagram:

Figure 8.3: The take operator

The prototype of the take operator is the following:

Observable.take(self, count, scheduler=None)

The count parameter indicates how many items must be emitted before the output observable completes.

The following is an example of the take operator:

numbers = Observable.from_([1, 2, 3, 4])numbers.take(2).subscribe(    on_next = lambda i: print("on_next {}".format(i)), on_error = lambda e: print("on_error: ...