Cumulo Pipeline
EventStream Pipeline for Cumulo Apps
Usage
npm i --save cumulo-pipeline
Pipeline = require 'cumulo-pipeline' p1 = p2 = p1forward p2 p2for consolelog 'got event'x p1send 'event'See test.cirru for more:
var Pipeline $ require :./src/pipeline var p1 $ new Pipeline p2 $ new Pipeline p1.forward p2p2.for $ \ (x) console.log :event x var p3 $ p1.map $ \ (x) return $ + ":::" x p3.for $ \ (x) console.log x p1.send :x var p4 $ p1.reduce 0 $ \ (a b) $ return $ + a b p4.for $ \ (x) console.log x var data $ [] 1 2 3 4 5data.forEach $ \ (x) (p1.send x)Methods
send and for are from Go syntax.
sendsend data into pipesforget data from pipesforwardsend data to next pipemapmap events into a new pipereducereduce events into a new pipe
License
MIT