@hackage / boombox

Chronokinetic stream sources and incremental consumers