Observables and AsyncIO

This last section will cover some operators that are specifically designed to deal with asynchronous operations. Some of them allow us to convert synchronous code to asynchronous code and others allow us to convert futures to streams, and vice versa.

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...