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")

run_limit = limit =>  {
  ^count = 0
  ^throttle = 1
  flow:compose(
    flow:drain_async,
    flow:chain(slog),
    flow:stop_when( _ => ++count > limit)
 )
}

run_limit(10)(step(100000, 999999999))