Daniel Arbuckle's Mastering Python

Creating an asyncio scheduler

We can create an asyncio scheduler using a simple command, as shown here:

scheduler = rx.concurrency.AsyncIOScheduler ()  

This is an Rx scheduler that specifically integrates with an asyncio event loop. Rx contains quite a few different scheduler implementations that integrate with various event loops available in Python, as well as one that uses Python threads to implement scheduling.

Regardless of which scheduler we use, the scheduler's job will be to decide when time-based elements of our event pipeline occur. This means that in this example, the scheduler is going to be deciding when our animal observables produce new values.

After creating the scheduler, we create the animal objects and their observable ...