Method handleSurplus

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

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

(
      pubsub: Atomic<A>,
      subscribers: Subscribers<A>,
      elements: Iterable<A>,
      isShutdown: MutableRef.MutableRef<boolean>
    )

Source from the content-addressed store, hash-verified

161	* waiting for space to become available in the `PubSub`.
162	*/
163	handleSurplus(
164	pubsub: Atomic<A>,
165	subscribers: Subscribers<A>,
166	elements: Iterable<A>,

PubSub.tsFile · 0.65

BackPressureStrategypackages/effect/src/PubSub.ts

DroppingStrategypackages/effect/src/PubSub.ts

SlidingStrategypackages/effect/src/PubSub.ts

no outgoing calls

no test coverage detected