flow-mumu 0.2.0-rc.9

Stream transform tools plugin for the Lava language
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15

extend("flow")
extend("math")
extend("std")

delay = flow:throttle(10)

run = flow:compose(
  flow:drain_async,
  delay,
  flow:chain(std:log),
  flow:chain(math:multiply(3))
)

run(step(1,10))