@thi.ng/rstream

Reactive Streams & subscription primitives for constructing dataflow graphs / pipelines. github