Dataflow

Functions

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