Skip to main content



flows()->Bag of Record

Get all current data flows

publish(Stream s,Charstring flow)->Stream

Publish elements in stream s in data flow

pump:active_flows(Charstring name)->Vector of Charstring

subscribe(Charstring flow)->Object

Follow data flow

subscribe(Charstring edge,Charstring flow)->Object

Follow data flow on edge

subscribe:merge(Vector of Charstring flows)->Object

subscribe:merge_tagged(Vector of Charstring flows)->Object

subscribe:pivot(Vector of Charstring flows)->Stream of Vector

subscribe:ts_pivot(Vector of Charstring flows)->Stream of Timeval of Vector