A library for managing asynchronous data flow observations and processes - View it on GitHub