Common lower-level functions needed by various streaming data libraries
https://github.com/fpco/streaming-commons