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
extend("flow")
extend("math")
extend("std")
extend("string")

run = flow:compose(
  flow:drain,
  flow:throttle(1000),
  flow:chain(std:log),
  flow:chain(string:concat("----"))
)

run(flow:read("examples/read-compose.mu"))