Map stream

Apply function fn to each chunk of data

map_stream(fn, ...)

Arguments

fn

function applied to each chunk of stream, the result of which is enqueued to the readable side

...

arguments passed to TransformStream

See also

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

Examples

mapper <- as_reader(1:10) %|>%
    map_stream(as.character) |>
    on("data", print)