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

Method completeSubscribersUnsafe

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

* Describes how publishers should signal to subscribers waiting for * additional values from the `PubSub` that new values are available.

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

Source from the content-addressed store, hash-verified

193 * additional values from the `PubSub` that new values are available.
194 */
195 completeSubscribersUnsafe(
196 pubsub: Atomic<A>,
197 subscribers: Subscribers<A>
198 ): void

Callers 1

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