Hands-On Reactive Programming with Python

Implementing an inotify driver

The structure of this driver is the same as the previous ones. The first step is to declare the types used in it:

Source = namedtuple('Source', ['response'])Sink = namedtuple('Sink', ['request'])# Sink objectsAddWatch = namedtuple('AddWatch', ['id', 'path', 'flags'])Start = namedtuple('Start', [])# Source objectsEvent = namedtuple('Event', ['id', 'path'])

This driver has one source observable and one sink observable. However, the API of this driver is not based on request/response. The inputs are requests, but the output is a continuous observable of inotify events. So a single request triggers many item emissions on the sink observable.

There are two possible sink items:

• The AddWatch item adds a new file to ...