The skip operator

The skip operator omits the first n items emitted by the input observable and emits all other items of the input observable on the output observable. The following figure shows the workings of this operator:

Figure 6.4: The skip operator

The prototype of this operator is the following one:

Observable.skip(self, count)

The count parameter is the number of items to skip before emitting some items.

Here is an example of the skip operator in use:

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

This example gives the following result:

on_next 3
on_next 4
on_next 5
on_completed

In this example, the first two items have been skipped, and the remaining three items have been forwarded.

..................Content has been hidden....................

You can't read the all page of ebook, please click here login for view all page.
Reset
3.22.216.254