Function timeoutEach

timeoutEach(ms: number): <T>(source: AsyncIterable<T>) => Stream<T>
Fails with TimeoutError if any individual upstream read reaches its ms millisecond deadline.

Elapsed time is checked when a read returns a value or completes the stream, even if the timer callback is delayed. A result at exactly the deadline is rejected. Idle time between downstream reads does not count. timeoutEach(0) fails on the first read without opening upstream. Terminal consumers still wait for in-flight work and cleanup before settling.
Parameters
- ms: number
Returns <T>(source: AsyncIterable<T>) => Stream<T>

Throws
If ms is not finite and non-negative.
timeoutEach<T>(ms: number): Operator<T, T>
Fails with TimeoutError if any individual upstream read reaches its ms millisecond deadline.

Elapsed time is checked when a read returns a value or completes the stream, even if the timer callback is delayed. A result at exactly the deadline is rejected. Idle time between downstream reads does not count. timeoutEach(0) fails on the first read without opening upstream. Terminal consumers still wait for in-flight work and cleanup before settling.
Type Parameters
- T
Parameters
- ms: number
Returns Operator<T, T>

Throws
If ms is not finite and non-negative.