Hands-On Reactive Programming with Python

Implementation of an Audio Transcoding Server

This chapter and the next two cover a realistic example of an application. This application uses the features and libraries described in previous chapters. It is based on RxPY, runs on an AsyncIO event loop, and uses the aiohttp package. The application is developed in a functional and reactive way. The first part describes how the project is structured. Since this application is more than a code snippet, its code is structured as a Python package. This part also contains some advice to improve the readability of the RxPY code. The second part presents Cyclotron, a framework that implements the code written in Chapter 3, Functional Programming with ReactiveX, to deal with observable cycles in ...