Function queuedScheduler

packages/effect/test/Semaphore.test.ts:388–406

(
        tasks: Array<() => void>,
        onOperation: (fiber: Fiber.Fiber<unknown, unknown>) => void
      )

  it.effect("queued withPermits interrupted at any operation does not leak permits", () =>
    Effect.gen(function*() {
      const queuedScheduler = (
        tasks: Array<() => void>,
        onOperation: (fiber: Fiber.Fiber<unknown, unknown>) => void
      ) => {
        const scheduler: Scheduler.Scheduler = {
          executionMode: "async",
          makeDispatcher: () => ({
            scheduleTask(task) {
              tasks.push(task)
            },
            flush() {}
          }),
          shouldYield: (fiber) => {
            onOperation(fiber)
            return false
          }
        }
        return scheduler
      }

      let operations = 0
      const baselineSem = yield* Semaphore.make(1)