• 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.)

    Type Parameters

    • T

    Parameters

    Returns Source<T>