Function makeImplLayer

packages/infra/test/routing-interruptibility.test.ts:23–35

(commandDone: Ref.Ref<boolean>, queryDone: Ref.Ref<boolean>)

)

const makeImplLayer = (commandDone: Ref.Ref<boolean>, queryDone: Ref.Ref<boolean>) =>
  InterruptibilityRpcs.toLayer({
    doCommand: () =>
      applyRequestTypeInterruptibility(
        "command",
        Effect.sleep("120 millis").pipe(Effect.andThen(Ref.set(commandDone, true)))
      ),
    doQuery: () =>
      applyRequestTypeInterruptibility(
        "query",
        Effect.sleep("120 millis").pipe(Effect.andThen(Ref.set(queryDone, true)))
      )
  })

describe("routing interruptibility", () => {
  it.live(