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

Method poll

packages/effect/src/PubSub.ts:111–111  ·  view source on GitHub ↗
()

Source from the content-addressed store, hash-verified

109 isEmpty(): boolean
110 size(): number
111 poll(): A | MutableList.Empty
112 pollUpTo(n: number): Array<A>
113 unsubscribe(): void
114 }

Callers 15

NodeTerminal.tsFile · 0.65
Workflow.test.tsFile · 0.65
TxQueue.test.tsFile · 0.65
TxPubSub.test.tsFile · 0.65
Queue.test.tsFile · 0.65
TxDeferred.test.tsFile · 0.65
Deferred.test.tsFile · 0.65
suiteFunction · 0.65
McpServer.test.tsFile · 0.65
WorkflowEngine.test.tsFile · 0.65
DurableQueue.test.tsFile · 0.65
ClusterWorkflowEngine.test.tsFile · 0.65

Implementers 4

BoundedPubSubArbSubscriptionpackages/effect/src/PubSub.ts
BoundedPubSubPow2Subscriptionpackages/effect/src/PubSub.ts
BoundedPubSubSingleSubscriptionpackages/effect/src/PubSub.ts
UnboundedPubSubSubscriptionpackages/effect/src/PubSub.ts

Calls

no outgoing calls

Tested by

no test coverage detected