Flatten a source of sources by emitting their contents until a new one
arrives.
As each source arrives from the input stream, its values are sent to the
output, closing the previous one (if any). The output is closed when both
the input stream and the most-recently-arrived stream are finished. Errors
propagate to the output if any stream throws.
(If you want to send all the values of each stream to the output without
stopping, input stream, use concatAll or mergeAll instead.)
Flatten a source of sources by emitting their contents until a new one arrives.
As each source arrives from the input stream, its values are sent to the output, closing the previous one (if any). The output is closed when both the input stream and the most-recently-arrived stream are finished. Errors propagate to the output if any stream throws.
(If you want to send all the values of each stream to the output without stopping, input stream, use concatAll or mergeAll instead.)