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