Version 3.0.3 is behind the current release: jump to latest version (3.1.0).
interface Queue
thefrontside/effectioninterface Queue<T, TClose> extends Subscription<T, TClose>
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.
Type Parameters
T the type of the items in the queue
TClose the type of the value that the queue is closed with
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.