MCPcopy Index your code
hub / github.com/Effect-TS/effect / poll

Function poll

packages/effect/src/internal/queue.ts:483–484  ·  view source on GitHub ↗
(self: Queue.Dequeue<A>)

Source from the content-addressed store, hash-verified

481
482/** @internal */
483export const poll = <A>(self: Queue.Dequeue<A>): Effect.Effect<Option.Option<A>> =>
484 core.map(self.takeUpTo(1), Chunk.head)
485
486/** @internal */
487export const take = <A>(self: Queue.Dequeue<A>): Effect.Effect<A> => self.take

Callers 2

SqlPersistedQueue.tsFile · 0.50
MutableQueue.tsFile · 0.50

Calls 2

mapMethod · 0.65
takeUpToMethod · 0.65

Tested by

no test coverage detected