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

Function takeUnsafe

repos/effect/packages/effect/src/Queue.ts:1525–1542  ·  view source on GitHub ↗
(self: Dequeue<A, E>)

Source from the content-addressed store, hash-verified

1523 * **Details**
1524 *
1525 * Returns an `Exit` for an immediately available message or for the queue's
1526 * terminal state. Returns `undefined` when no message is immediately available.
1527 * This operation does not wait or register a taker.
1528 *
1529 * **Example** (Taking one value synchronously)
1530 *
1531 * ```ts import.meta.vitest
1532 * import { Effect, Exit, Queue } from "effect"
1533 *
1534 * // Create a queue and use unsafe operations
1535 * const program = Effect.gen(function*() {
1536 * const queue = yield* Queue.bounded<number>(10)
1537 *
1538 * // Add some messages
1539 * Queue.offerUnsafe(queue, 1)
1540 * Queue.offerUnsafe(queue, 2)
1541 *
1542 * // Take a message synchronously
1543 * const result1 = Queue.takeUnsafe(queue)
1544 *
1545 * const result2 = Queue.takeUnsafe(queue)

Callers 2

takeFunction · 0.85
pollFunction · 0.85

Calls 2

releaseCapacityFunction · 0.85
takeMethod · 0.65

Tested by

no test coverage detected

Used in the wild real call sites across dependent graphs

searching dependent graphs…