MCPcopy Create free account
hub / github.com/Effect-TS/effect / onPubSubEmptySpaceUnsafe

Method onPubSubEmptySpaceUnsafe

packages/effect/src/PubSub.ts:174–174  ·  view source on GitHub ↗

* Describes how subscribers should signal to publishers waiting for space * to become available in the `PubSub` that space may be available.

(
      pubsub: Atomic<A>,
      subscribers: Subscribers<A>
    )

Source from the content-addressed store, hash-verified

172 * to become available in the `PubSub` that space may be available.
173 */
174 onPubSubEmptySpaceUnsafe(
175 pubsub: Atomic<A>,
176 subscribers: Subscribers<A>
177 ): void

Callers 5

unsubscribeFunction · 0.65
takeFunction · 0.65
takeAllFunction · 0.65
PubSub.tsFile · 0.65

Implementers 3

BackPressureStrategypackages/effect/src/PubSub.ts
DroppingStrategypackages/effect/src/PubSub.ts
SlidingStrategypackages/effect/src/PubSub.ts

Calls

no outgoing calls

Tested by

no test coverage detected