Batch stream — batch_stream • streams

Chunks that flow through a stream will be grouped into lists of length size before being enqueued

batch_stream(size, ...)

Arguments

size: the maximum length of each batch
...: arguments passed to TransformStream

See also

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

Examples

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