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

    Function merge

    • Merges multiple sources concurrently, holding at most one pending read or buffered result per source.

      Ready sources are polled in round-robin order, and no new reads start while downstream is idle.

      Type Parameters

      • const S extends readonly Source<unknown>[]

      Parameters

      • ...sources: S

      Returns Stream<SourceValues<S>[number]>

    • Merges multiple sources concurrently, holding at most one pending read or buffered result per source.

      Ready sources are polled in round-robin order, and no new reads start while downstream is idle.

      Type Parameters

      • T

      Parameters

      Returns Stream<T>