1 2 3 4 5 6 7 8 9 10 11 12 13
extend("flow") run = flow:compose( flow:drain_async, flow:chain(slog), flow:throttle(0), flow:filter(x => !(x % 97)) ) run(step(1,100000))