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

extend("flow")

run = flow:compose(
  flow:drain_async,
  flow:chain(slog),
  flow:throttle(100)
)

run(step(1,10))
run(step(1,20))