(executionId: string, response: ResumeResponse)
| 1122 | const onResumeSettled = (executionId: string): Effect.Effect<void> => |
| 1123 | config.pausedExecutionHooks?.onResumeSettled?.(executionId) ?? Effect.void; |
| 1124 | const resumeWithLifecycle = (executionId: string, response: ResumeResponse) => |
| 1125 | Effect.gen(function* () { |
| 1126 | yield* onResumeStarted(executionId); |
| 1127 | return yield* engine.resume(executionId, response); |
| 1128 | }).pipe(Effect.ensuring(onResumeSettled(executionId))); |
| 1129 | |
| 1130 | const localExecutionAlreadySettled = (executionId: string): Effect.Effect<boolean> => |
| 1131 | engine.isExecutionSettled?.(executionId) ?? Effect.succeed(false); |
no test coverage detected