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

Function poll

packages/effect/src/unstable/persistence/PersistedQueue.ts:445–453  ·  view source on GitHub ↗
(size: number)

Source from the content-addressed store, hash-verified

443 )
444
445 const poll = (size: number) =>
446 take(
447 queueKey,
448 pendingKey,
449 prefix,
450 workerId,
451 size,
452 lockExpirationMillis
453 )
454
455 yield* Effect.gen(function*() {
456 while (true) {

Callers 1

PersistedQueue.tsFile · 0.70

Calls 1

takeFunction · 0.50

Tested by

no test coverage detected