Collect stream — collect_stream • streams

Form of reduce stream where all data is appended to a list before being emitted.

collect_stream(...)

Arguments

...: arguments passed to reduce_stream

See also

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

Examples

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