flatten_stream.Rd
Chunks that pass through the stream are flattened one-level and their individual elements are enqueued
flatten_stream(...)
arguments passed to TransformStream
Other functionals:
batch_stream()
,
collect_stream()
,
filter_stream()
,
limit_stream()
,
map_stream()
,
reduce_stream()
,
walk_stream()