//#region src/interrupt.d.ts /** * Interrupts the execution of a graph node. * This function can be used to pause execution of a node, and return the value of the `resume` * input when the graph is re-invoked using `Command`. * Multiple interrupts can be called within a single node, and each will be handled sequentially. * * When an interrupt is called: * 1. If there's a `resume` value available (from a previous `Command`), it returns that value. * 2. Otherwise, it throws a `GraphInterrupt` with the provided value * 3. The graph can be resumed by passing a `Command` with a `resume` value * * Because the `interrupt` function propagates by throwing a special `GraphInterrupt` error, * you should avoid using `try/catch` blocks around the `interrupt` function, * or if you do, ensure that the `GraphInterrupt` error is thrown again within your `catch` block. * * @param value - The value to include in the interrupt. This will be available in task.interrupts[].value * @returns The `resume` value provided when the graph is re-invoked with a Command * * @example * ```typescript * // Define a node that uses multiple interrupts * const nodeWithInterrupts = () => { * // First interrupt - will pause execution and include {value: 1} in task values * const answer1 = interrupt({ value: 1 }); * * // Second interrupt - only called after first interrupt is resumed * const answer2 = interrupt({ value: 2 }); * * // Use the resume values * return { myKey: answer1 + " " + answer2 }; * }; * * // Resume the graph after first interrupt * await graph.stream(new Command({ resume: "answer 1" })); * * // Resume the graph after second interrupt * await graph.stream(new Command({ resume: "answer 2" })); * // Final result: { myKey: "answer 1 answer 2" } * ``` * * @throws {Error} If called outside the context of a graph * @throws {GraphInterrupt} When no resume value is available */ declare function interrupt(value: I): R; type FilterAny = (() => T extends X ? 1 : 2) extends (() => (T extends any ? 1 : 2)) ? never : X; type InferInterruptInputType = T extends typeof interrupt ? I : T extends { [key: string]: typeof interrupt; } ? { [K in keyof T]: InferInterruptInputType }[keyof T] : unknown; type InferInterruptResumeType = T extends typeof interrupt ? TInner extends true ? FilterAny : R : T extends { [key: string]: typeof interrupt; } ? { [K in keyof T]: InferInterruptResumeType }[keyof T] : unknown; //#endregion export { InferInterruptInputType, InferInterruptResumeType, interrupt }; //# sourceMappingURL=interrupt.d.ts.map