Function makeDeferredEngine

packages/workflow/test/WorkflowEngine.test.ts:131–145

(exits: Array<Exit.Exit<number, string>>)

})

const makeDeferredEngine = (exits: Array<Exit.Exit<number, string>>): WorkflowEngine.WorkflowEngine["Type"] =>
  WorkflowEngine.WorkflowEngine.of({
    register: () => Effect.void,
    execute: () => Effect.die("not implemented"),
    poll: () => Effect.succeed(undefined),
    interrupt: () => Effect.void,
    resume: () => Effect.void,
    activityExecute: () => Effect.die("not implemented"),
    deferredResult: () => Effect.succeed(undefined),
    deferredDone: (_deferred: DurableDeferred.Any, options: { readonly exit: Exit.Exit<unknown, unknown> }) =>
      Effect.sync(() => {
        exits.push(options.exit as Exit.Exit<number, string>)
      }),
    scheduleClock: () => Effect.void
  } as any)

const LongWorkflow = Workflow.make({
  name: "LongWorkflow",