Hands-On Reactive Programming with Python

Summary

This chapter concludes the implementation of the audio-transcoding server. This application is now robust enough to be used in production. The two parts studied in this chapter provide other examples of how to use RxPY in non-trivial cases.

The usage of aionotify is another example of how to integrate an AsyncIO package with RxPY, and in a functional way. inotify is different from the other drivers that have been written before because it does not implement a request/response communication pattern, but an observer one (which is more similar to ReactiveX observables). With this example, you should now be able to use any AsyncIO package in an RxPY application.

The second part covers a very important aspect of any serious application—error ...