Hands-On Reactive Programming with Python

The of operator

The of operator is a variant of the from_ operator. This operator creates an observable from a variable number of arguments. The marble diagram of this operator is shown in the following diagram:

Figure 4.1: The of operator

Its prototype is as follows:

Observable.of(*args, **kwargs)

The scheduler can be provided as the optional scheduler keyword argument. This operator can be used with values directly passed to it, as follows:

numbers = Observable.of(1, 2, 3, 4)numbers.subscribe(        on_next=lambda i: print("item: {}".format(i)),        on_error=lambda e: print("error: {}".format(e)),        on_completed=lambda: print("completed")    )

Upon subscription, ...