effect-io-ai

Package: effect
Module: Stream

Stream.timeoutFail

Fails the stream with given error if it does not produce a value after d duration.

Signature

declare const timeoutFail: { <E2>(error: LazyArg<E2>, duration: Duration.DurationInput): <A, E, R>(self: Stream<A, E, R>) => Stream<A, E2 | E, R>; <A, E, R, E2>(self: Stream<A, E, R>, error: LazyArg<E2>, duration: Duration.DurationInput): Stream<A, E | E2, R>; }

Source

Since v2.0.0