Function deadline

deadline(durationMs: number): <T>(source: AsyncIterable<T>) => Stream<T>
Fails with DeadlineExceededError if the stage remains open longer than durationMs milliseconds after its first read.

Elapsed time includes both upstream reads and downstream idle time. deadline(0) fails immediately without opening upstream.
Parameters
- durationMs: number
Returns <T>(source: AsyncIterable<T>) => Stream<T>

Throws
If durationMs is not finite and non-negative.
deadline<T>(durationMs: number): Operator<T, T>
Fails with DeadlineExceededError if the stage remains open longer than durationMs milliseconds after its first read.

Elapsed time includes both upstream reads and downstream idle time. deadline(0) fails immediately without opening upstream.
Type Parameters
- T
Parameters
- durationMs: number
Returns Operator<T, T>

Throws
If durationMs is not finite and non-negative.