MCPcopy Index your code
hub / github.com/Effect-TS/effect / unsafeRemove

Method unsafeRemove

packages/effect/src/internal/pubsub.ts:1503–1508  ·  view source on GitHub ↗
(deferred: Deferred.Deferred<boolean>)

Source from the content-addressed store, hash-verified

1501 }
1502
1503 unsafeRemove(deferred: Deferred.Deferred<boolean>): void {
1504 unsafeOfferAll(
1505 this.publishers,
1506 pipe(unsafePollAllQueue(this.publishers), Chunk.filter(([_, a]) => a !== deferred))
1507 )
1508 }
1509}
1510
1511/**

Callers 1

handleSurplusMethod · 0.95

Calls 3

unsafePollAllQueueFunction · 0.85
unsafeOfferAllFunction · 0.70
pipeFunction · 0.70

Tested by

no test coverage detected