Method cached

packages/effect/src/Scheduler.ts:69–86

* @since 3.20.0 * @category constructors

(
    scheduleDrain: (depth: number, drain: (depth: number) => void) => void
  )

   * @category constructors
   */
  static cached(
    scheduleDrain: (depth: number, drain: (depth: number) => void) => void
  ) {
    const fallback = new SchedulerRunner(scheduleDrain)
    const runners = new WeakMap<RuntimeFiber<unknown, unknown>, SchedulerRunner>()

    return (fiber?: RuntimeFiber<unknown, unknown>) => {
      if (fiber === undefined) {
        return fallback
      }
      let runner = runners.get(fiber)
      if (runner === undefined) {
        runner = new SchedulerRunner(scheduleDrain)
        runners.set(fiber, runner)
      }
      return runner
    }
  }
}

/**