mogami-stream - v0.2.0
    Preparing search index...

    Function flatten

    • Flattens a stream of child sources, interleaving values when concurrency > 1.

      Each active child holds a single read/result slot and occupies a concurrency slot until its cleanup finishes. A child's cleanup does not block values from other active children.

      Type Parameters

      • T

      Parameters

      Returns Operator<Source<T>, T>

      If concurrency is not a positive safe integer.