Function completeStep

packages/infra/test/cluster-sqlite.test.ts:141–152

(
  deferred: DurableDeferred.DurableDeferred<Success, Schema.Never>,
  payload: { readonly id: string },
  value: Success["Type"]
)

      )
    )
}

const completeStep = <Success extends Schema.Top>(
  deferred: DurableDeferred.DurableDeferred<Success, Schema.Never>,
  payload: { readonly id: string },
  value: Success["Type"]
) =>
  Effect.gen(function*() {
    const token = yield* DurableDeferred.tokenFromPayload(deferred, {
      workflow: SequentialDeferredWorkflow,
      payload
    })
    yield* DurableDeferred.done(deferred, { token, exit: Exit.succeed(value) })
  })