hub / github.com/Effect-TS/effect / completePollersUnsafe

Method completePollersUnsafe

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

* Describes how subscribers waiting for additional values from the `PubSub` * should take those values and signal to publishers that they are no * longer waiting for additional values.

(
      pubsub: Atomic<A>,
      subscribers: Subscribers<A>,
      subscription: BackingSubscription<A>,
      pollers: MutableList.MutableList<Deferred.Deferred<A>>
    )

Source from the content-addressed store, hash-verified

182	* longer waiting for additional values.
183	*/
184	completePollersUnsafe(
185	pubsub: Atomic<A>,
186	subscribers: Subscribers<A>,
187	subscription: BackingSubscription<A>,

Callers 2

pollForItemFunction · 0.65

strategyCompleteSubscribersUnsafeFunction · 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