Common lower-level functions needed by various streaming data libraries - View it on GitHub