Hands-On Reactive Programming with Python

The start operator

The start operator schedules the execution of a function asynchronously and emits its result in an observable. The marble diagram of the start operator is shown in the following figure:

Figure 4.17: The start operator

Its prototype is as follows:

Observable.start(func, scheduler=None)

The function provided as an argument is scheduled immediately, not during the subscription. If no scheduler is provided, the timeout scheduler is used (see Chapter 5, Concurrency and Parallelism in RxPY, for details on schedulers), with a timeout value of 0; that is, no timeout. In this case, the execution of the func function is still done ...