Skip to main content
Module

x/effection/lib/queue.ts>Queue

Structured concurrency and effects for JavaScript
thefrontside/effection
Latest
interface Queue
implements Subscription<T, TClose>
import { type Queue } from "https://deno.land/x/effection@3.0.3/lib/queue.ts";

A FIFO queue which can be used to implement the Subscription interface directly. Most of the time, you will use either a Signal or a Channel as the mechanism, but Queue allows you to manage a single subscription directly.

Methods

add(item: T): void

Add a value to the queue. The oldest value currently in the queue will be the first to be read.

close(value: TClose): void

Close the queue.