• Merges elements from all inner async-iterable sequences into a single async-iterable sequence.

    Parameters

    • concurrent: number = Infinity

    Returns (<TSource>(source) => FlattenConcurrentAsyncIterable<AsyncIterable<TSource>, TSource>)

    The async-iterable sequence that merges the elements of the inner sequences.

      • <TSource>(source): FlattenConcurrentAsyncIterable<AsyncIterable<TSource>, TSource>
      • Type Parameters

        • TSource

        Parameters

        • source: AsyncIterable<AsyncIterable<TSource>>

        Returns FlattenConcurrentAsyncIterable<AsyncIterable<TSource>, TSource>

Generated using TypeDoc