Negligent Parachute Maintainers
Miss any of our Open RFC calls?Watch the recordings here! »

cumulo-pipeline

0.0.3 • Public • Published

Cumulo Pipeline

EventStream Pipeline for Cumulo Apps

Usage

npm i --save cumulo-pipeline
Pipeline = require 'cumulo-pipeline'
 
p1 = new Pipeline
p2 = new Pipeline
p1.forward p2
 
p2.for (x) -> console.log 'got event'x
 
p1.send 'event'

See test.cirru for more:

 
var
  Pipeline $ require :./src/pipeline
 
var
  p1 $ new Pipeline
  p2 $ new Pipeline
 
p1.forward p2
p2.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 5
data.forEach $ \ (x) (p1.send x)

Methods

send and for are from Go syntax.

  • send send data into pipes
  • for get data from pipes
  • forward send data to next pipe
  • map map events into a new pipe
  • reduce reduce events into a new pipe

License

MIT

Install

npm i cumulo-pipeline

DownloadsWeekly Downloads

1

Version

0.0.3

License

MIT

Last publish

Collaborators

  • avatar