(self: Enqueue<A, E>)
| 1112 | * **Example** (Shutting down queues) |
| 1113 | * |
| 1114 | * ```ts import.meta.vitest |
| 1115 | * import { Effect, Queue } from "effect" |
| 1116 | * |
| 1117 | * const program = Effect.gen(function*() { |
| 1118 | * const queue = yield* Queue.bounded<number>(2) |
| 1119 | * |
| 1120 | * // Add messages |
| 1121 | * yield* Queue.offer(queue, 1) |
| 1122 | * yield* Queue.offer(queue, 2) |
| 1123 | * |
| 1124 | * // Shutdown clears buffered messages and prevents further offers |
| 1125 | * const wasShutdown = yield* Queue.shutdown(queue) |
| 1126 | * |
| 1127 | * // Queue is now done and cleared |
| 1128 | * const size = yield* Queue.size(queue) |
| 1129 | * return { wasShutdown, size } |
| 1130 | * }) |
| 1131 | * |
| 1132 | * await Effect.runPromise(program) // => { wasShutdown: true, size: 0 } |
| 1133 | * ``` |
| 1134 | * |
| 1135 | * @category completion |
| 1136 | * @since 2.0.0 |
no test coverage detected
searching dependent graphs…