flatten_stream.RdChunks 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()