Class FiberRuntime

packages/effect/src/internal/fiberRuntime.ts:293–1437

/** @internal */
export class FiberRuntime<in out A, in out E = never> extends Effectable.Class<A, E>
  implements Fiber.RuntimeFiber<A, E>
{
  readonly [internalFiber.FiberTypeId] = internalFiber.fiberVariance
  readonly [internalFiber.RuntimeFiberTypeId] = runtimeFiberVariance
  private _fiberRefs: FiberRefs.FiberRefs
  private _fiberId: FiberId.Runtime
  private _queue = new Array<FiberMessage.FiberMessage>()
  private _children: Set<FiberRuntime<any, any>> | null = null
  private _observers = new Array<(exit: Exit.Exit<A, E>) => void>()
  private _running = false
  private _stack: Array<core.Continuation> = []
  private _asyncInterruptor: ((effect: Effect.Effect<any, any, any>) => any) | null = null
  private _asyncBlockingOn: FiberId.FiberId | null = null
  private _exitValue: Exit.Exit<A, E> | null = null
  private _steps: Array<Snapshot> = []
  private _isYielding = false

  public currentRuntimeFlags: RuntimeFlags.RuntimeFlags
  public currentOpCount: number = 0
  public currentSupervisor!: Supervisor.Supervisor<any>
  public currentScheduler!: Scheduler
  public currentTracer!: Tracer.Tracer
  public currentSpan!: Tracer.AnySpan | undefined
  public currentContext!: Context.Context<never>
  public currentDefaultServices!: Context.Context<DefaultServices>

  constructor(
    fiberId: FiberId.Runtime,
    fiberRefs0: FiberRefs.FiberRefs,
    runtimeFlags0: RuntimeFlags.RuntimeFlags
  ) {
    super()
    this.currentRuntimeFlags = runtimeFlags0
    this._fiberId = fiberId
    this._fiberRefs = fiberRefs0
    if (runtimeFlags_.runtimeMetrics(runtimeFlags0)) {
      const tags = this.getFiberRef(core.currentMetricLabels)
      fiberStarted.unsafeUpdate(1, tags)
      fiberActive.unsafeUpdate(1, tags)
    }
    this.refreshRefCache()
  }

  commit(): Effect.Effect<A, E, never> {
    return internalFiber.join(this)
  }

  /**
   * The identity of the fiber.
   */
  id(): FiberId.Runtime {
    return this._fiberId
  }

  /**
   * Begins execution of the effect associated with this fiber on in the
   * background. This can be called to "kick off" execution of a fiber after