Method interruptUnsafe

packages/effect/src/internal/effect.ts:573–594

(fiberId?: number | undefined, annotations?: Context.Context<never> | undefined)

    }
  }
  interruptUnsafe(fiberId?: number | undefined, annotations?: Context.Context<never> | undefined): void {
    if (this._exit) {
      return
    }
    let cause = causeInterrupt(fiberId)
    if (this.currentStackFrame) {
      cause = causeAnnotate(cause, Context.make(CauseStackTrace, this.currentStackFrame))
    }
    if (annotations) {
      cause = causeAnnotate(cause, annotations)
    }
    this._interruptedCause = this._interruptedCause
      ? causeCombine(this._interruptedCause, cause)
      : cause
    if (this.interruptible) {
      if (this._running) {
        this._deferredInterrupt = true
      } else {
        this.evaluate(failCause(this._interruptedCause) as any)
      }
    }
  }
  pollUnsafe(): Exit.Exit<A, E> | undefined {
    return this._exit
  }