(executionId: string, response: ResumeResponse)
| 1101 | const onResumeSettled = (executionId: string): Effect.Effect<void> => |
| 1102 | config.pausedExecutionHooks?.onResumeSettled?.(executionId) ?? Effect.void; |
| 1103 | const resumeWithLifecycle = (executionId: string, response: ResumeResponse) => |
| 1104 | Effect.gen(function* () { |
| 1105 | yield* onResumeStarted(executionId); |
| 1106 | return yield* engine.resume(executionId, response); |
| 1107 | }).pipe(Effect.ensuring(onResumeSettled(executionId))); |
| 1108 | |
| 1109 | const localExecutionAlreadySettled = (executionId: string): Effect.Effect<boolean> => |
| 1110 | engine.isExecutionSettled?.(executionId) ?? Effect.succeed(false); |
no test coverage detected