Reactive streams & subscription primitives for constructing dataflow graphs / pipelines. github
See also rstream-graph
rstream