• Flatten a source of sources by emitting their contents in series

    Streams are concatenated in order -- note that this means they need to not be infinite if any subsequent streams are to be processed! The output is closed when all sources are finished or if any source throws (in which case the error propagates to the subscriber).

    If you want to switch to a new stream whenever a new source arrives from the input stream, use switchAll instead.

    Type Parameters

    • T

    Parameters

    Returns Source<T>