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

    Function zipLatest

    • Emits tuples containing the latest value observed from each source.

      By default (partial: false), waits until every source has emitted at least once before producing a tuple. With partial: true, emits immediately and fills unseen positions with undefined. Updates arriving before the first tuple is ready may coalesce; afterward, reads are driven by downstream demand.

      Type Parameters

      • const S extends readonly Source<unknown>[]

      Parameters

      • sources: S
      • options: { partial: true }

      Returns Stream<PartialSourceValues<S>>

    • Emits tuples containing the latest value observed from each source.

      By default (partial: false), waits until every source has emitted at least once before producing a tuple. With partial: true, emits immediately and fills unseen positions with undefined. Updates arriving before the first tuple is ready may coalesce; afterward, reads are driven by downstream demand.

      Type Parameters

      • const S extends readonly Source<unknown>[]

      Parameters

      • sources: S
      • Optionaloptions: { partial?: false }

      Returns Stream<SourceValues<S>>

    • Emits tuples containing the latest value observed from each source.

      By default (partial: false), waits until every source has emitted at least once before producing a tuple. With partial: true, emits immediately and fills unseen positions with undefined. Updates arriving before the first tuple is ready may coalesce; afterward, reads are driven by downstream demand.

      Type Parameters

      • const S extends readonly Source<unknown>[]

      Parameters

      Returns Stream<PartialSourceValues<S>>