extend("flow")
extend("net")
extend("json")
run = int#delay => flow:compose(
flow:drain_async,
flow:chain(
row => slog(json:encode(row))
),
flow:throttle(delay)
)
run(0)(
net:ping([dest:"8.8.8.8"])
)
/*
run(1000)(
net:ping([dest:"nu11.uk"])
)
run(1000)(
net:ping([dest:"172.16.4.5"])
)
run(1000)(
net:ping([dest:"evoux.pipeux.net"])
)