import type * as T from "../../../../Effect/index.js"; import * as C from "../core.js"; /** * Interrupts the evaluation of this stream when the provided IO completes. The given * IO will be forked as part of this stream, and its success will be discarded. This * combinator will also interrupt any in-progress element being pulled from upstream. * * If the IO completes with a failure before the stream completes, the returned stream * will emit that failure. */ export declare function interruptWhen_(self: C.Stream, io: T.Effect): C.Stream; /** * Interrupts the evaluation of this stream when the provided IO completes. The given * IO will be forked as part of this stream, and its success will be discarded. This * combinator will also interrupt any in-progress element being pulled from upstream. * * If the IO completes with a failure before the stream completes, the returned stream * will emit that failure. * * @ets_data_first interruptWhen_ */ export declare function interruptWhen(io: T.Effect): (self: C.Stream) => C.Stream; //# sourceMappingURL=interruptWhen.d.ts.map