Method unsafeRebuild

packages/cluster/src/internal/resourceRef.ts:58–80

()

  }

  unsafeRebuild(): Effect.Effect<void, E> {
    const s = this.state.current
    if (s._tag === "Closed") {
      return Effect.interrupt
    }
    const prevScope = s.scope
    const scope = Effect.runSync(Scope.make())
    this.latch.unsafeClose()
    MutableRef.set(this.state, { _tag: "Acquiring", scope })
    return Effect.fiberIdWith((fiberId) => {
      internalInterruptors.add(fiberId)
      return Scope.close(prevScope, Exit.void)
    }).pipe(
      Effect.andThen(this.acquire(scope)),
      Effect.flatMap((value) => {
        if (this.state.current._tag === "Closed") {
          return Effect.interrupt
        }
        MutableRef.set(this.state, { _tag: "Acquired", scope, value })
        return this.latch.open
      })
    )
  }

  await: Effect.Effect<A> = Effect.suspend(() => {
    const s = this.state.current