MCPcopy Create free account
hub / github.com/effect-app/libs / shutdown

Method shutdown

repos/effect/packages/effect/src/PubSub.ts:2604–2606  ·  view source on GitHub ↗
()

Source from the content-addressed store, hash-verified

2602 //
2603 }
2604
2605 completePollersUnsafe(
2606 pubsub: PubSub.Atomic<A>,
2607 subscribers: PubSub.Subscribers<A>,
2608 subscription: PubSub.BackingSubscription<A>,
2609 pollers: MutableList.MutableList<Deferred.Deferred<A>>

Callers 15

TxQueue.test.tsFile · 0.45
PubSub.test.tsFile · 0.45
TxPubSub.test.tsFile · 0.45
Queue.test.tsFile · 0.45
Stream.test.tsFile · 0.45
MockTerminal.tsFile · 0.45
asyncQueueFunction · 0.45
mapEffectConcurrentFunction · 0.45
Channel.tsFile · 0.45
TxPubSub.tsFile · 0.45
shutdownFunction · 0.45
Stream.tsFile · 0.45

Calls

no outgoing calls

Tested by

no test coverage detected