Walk stream

Map stream, but for side-effects

walk_stream(fn, ...)

Arguments

fn

function applied to each chunk of the stream, but does not enqueue the changed chunk

...

arguments passed to TransformStream

See also

Other functionals: batch_stream(), collect_stream(), filter_stream(), flatten_stream(), limit_stream(), map_stream(), reduce_stream()

Examples

as_reader(1:10) %|>%
 walk_stream(print) |>
 on("data", print)