Hands-On Reactive Programming with Python

Putting it all together

Now, all the drivers and base blocks are available. These elements must be combined together, via a component that is the entry point of the application. Let's define the APIs of this component:

Drivers = namedtuple('Drivers', ['encoder', 'httpd', 'file', 'argv'])Source = namedtuple('Source', ['encoder', 'httpd', 'file', 'argv'])Sink = namedtuple('Sink', ['encoder', 'httpd', 'file'])

Four drivers are used in total:

• The encoder especially implemented for this application
• The httpd driver from the cyclotron-aio package
• The file and argv drivers from the cyclotron-std package

Each of these drivers emits source items that are used by the application. So, the Source object also contains the same four fields. However, ...