Skip to main content


Structured concurrency and effects for JavaScript
Go to Latest
interface Queue
implements Subscription<T, TClose>
import { type Queue } from "";

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.


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.