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

Method poll

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

Source from the content-addressed store, hash-verified

108 export interface BackingSubscription<out A> {
109 isEmpty(): boolean
110 size(): number
111 poll(): A | MutableList.Empty
112 pollUpTo(n: number): Array<A>
113 unsubscribe(): void

Callers 15

waitForDeferredWorkflowSuspendedFunction · 0.65
waitForDeferredWorkflowCompleteFunction · 0.65
workflow-engine-sqlite.test.tsFile · 0.65
waitForSuspendedFunction · 0.65
waitForDeferredWorkflowCompleteFunction · 0.65
waitForCompleteFunction · 0.65
runSuiteFunction · 0.65
workflow-engine-cosmos.test.tsFile · 0.65
TxQueue.test.tsFile · 0.65
Queue.test.tsFile · 0.65
TxDeferred.test.tsFile · 0.65
Deferred.test.tsFile · 0.65

Implementers 4

BoundedPubSubArbSubscriptionrepos/effect/packages/effect/src/PubSu
BoundedPubSubPow2Subscriptionrepos/effect/packages/effect/src/PubSu
BoundedPubSubSingleSubscriptionrepos/effect/packages/effect/src/PubSu
UnboundedPubSubSubscriptionrepos/effect/packages/effect/src/PubSu

Calls

no outgoing calls

Tested by 6

waitForDeferredWorkflowSuspendedFunction · 0.52
waitForDeferredWorkflowCompleteFunction · 0.52
waitForSuspendedFunction · 0.52
waitForDeferredWorkflowCompleteFunction · 0.52
waitForCompleteFunction · 0.52
runSuiteFunction · 0.52