MCPcopy Create free account
hub / github.com/effect-app/libs / PubSub.ts

File PubSub.ts

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

Source from the content-addressed store, hash-verified

1/**
2 * Broadcasts values from publishers to many subscribers.
3 *
4 * Publishers add messages with `publish` or `publishAll`, and each active

Callers

nothing calls this directly

Calls 10

takeRemainderLoopFunction · 0.85
publishMethod · 0.65
completeSubscribersUnsafeMethod · 0.65
handleSurplusMethod · 0.65
publishAllMethod · 0.65
takeNMethod · 0.65
takeAllMethod · 0.65
pollUpToMethod · 0.65
onPubSubEmptySpaceUnsafeMethod · 0.65
succeedMethod · 0.45

Tested by

no test coverage detected