Function waitForSuspended

packages/infra/test/cluster-sqlite.test.ts:159–176

(
  workflow: {
    readonly poll: (
      executionId: string
    ) => Effect.Effect<Option.Option<Workflow.Result<A, E>>, never, R>
  },
  executionId: string
)

const waitForSequentialWorkflowSuspended = (executionId: string) =>
  waitForSuspended(SequentialDeferredWorkflow, executionId)

const waitForSuspended = <A, E, R>(
  workflow: {
    readonly poll: (
      executionId: string
    ) => Effect.Effect<Option.Option<Workflow.Result<A, E>>, never, R>
  },
  executionId: string
) =>
  Effect.gen(function*() {
    const sharding = yield* Sharding.Sharding
    for (let i = 0; i < 100; i++) {
      yield* sharding.pollStorage
      const polled = yield* workflow.poll(executionId)
      if (Option.isSome(polled) && polled.value._tag === "Suspended") return
      yield* Effect.sleep(Duration.millis(100))
    }
    return yield* Effect.fail(new Error(`Workflow ${executionId} did not suspend`))
  })