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

    Function spaceout

    • Emits the first value without added delay, then ensures at least intervalMs milliseconds between subsequent emissions.

      Time spent waiting for upstream reads or downstream demand counts toward the interval.

      Parameters

      • intervalMs: number

      Returns <T>(source: AsyncIterable<T>) => Stream<T>

      If intervalMs is not finite and non-negative.

    • Emits the first value without added delay, then ensures at least intervalMs milliseconds between subsequent emissions.

      Time spent waiting for upstream reads or downstream demand counts toward the interval.

      Type Parameters

      • T

      Parameters

      • intervalMs: number

      Returns Operator<T, T>

      If intervalMs is not finite and non-negative.