Function runtime

packages/effect/src/FiberSet.ts:564–583

(self: FiberSet<A, E>)

  never,
  R
> = <A, E>(self: FiberSet<A, E>) => <R>() =>
  Effect.map(
    Effect.context<R>(),
    (services) => {
      const runFork = Effect.runForkWith(services)
      return <XE extends E, XA extends A>(
        effect: Effect.Effect<XA, XE, R>,
        options?:
          | Effect.RunOptions & { readonly propagateInterruption?: boolean | undefined }
          | undefined
      ) => {
        if (self.state._tag === "Closed") {
          return constInterruptedFiber()
        }
        const fiber = runFork(effect, options)
        addUnsafe(self, fiber, options)
        return fiber
      }
    }
  )

/**
 * Captures a `Runtime` and returns a Promise-based runner that forks effects