Method run

src/internal/fiberStore.ts:65–93

(stream: Stream.Stream<R, E, A>)

    }
    | undefined = undefined
  public run(stream: Stream.Stream<R, E, A>) {
    this.interruptIfRunning()
    this.stream = stream

    const interruptedRef = Ref.unsafeMake(false)
    const maybeSetResult = (result: Result.Result<E, A>) =>
      Effect.flatMap(
        Ref.get(interruptedRef),
        (interrupted) =>
          interrupted
            ? Effect.unit
            : Effect.sync(() => this.setResult(result))
      )

    const fiber = pipe(
      Stream.suspend(() => {
        this.setResult(Result.waiting(this.resultBag.result))
        return stream
      }),
      Stream.runForEach((_) => maybeSetResult(Result.success(_))),
      Effect.catchAllCause((cause) => maybeSetResult(Result.failCause(cause))),
      Runtime.runFork(this.runtime)
    )

    this.fiberState = {
      fiber,
      interruptedRef
    }
  }
  public interruptIfRunning() {
    if (this.fiberState) {
      Effect.runFork(