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

Method handleSurplus

packages/effect/src/internal/pubsub.ts:1352–1352  ·  view source on GitHub ↗

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

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

Source from the content-addressed store, hash-verified

1350 * waiting for space to become available in the `PubSub`.
1351 */
1352 handleSurplus(
1353 pubsub: AtomicPubSub<A>,
1354 subscribers: Subscribers<A>,
1355 elements: Iterable<A>,

Callers 4

publishMethod · 0.65
publishAllMethod · 0.65
offerMethod · 0.65
offerAllMethod · 0.65

Implementers 3

BackPressureStrategypackages/effect/src/internal/pubsub.ts
DroppingStrategypackages/effect/src/internal/pubsub.ts
SlidingStrategypackages/effect/src/internal/pubsub.ts

Calls

no outgoing calls

Tested by

no test coverage detected