Class Channel<T>

Closes channel for both reading and writing.

Idempotent: a channel that is already closed for writing (for example a producer that finished before the consumer stopped iterating) is drained without throwing.

Closes writing only.

Writes beyond capacity are settled with optional err.

If there are no pending writes channel is effectively done - closed for reading and writing.

Fails the channel: closes it for reading and writing, rejects pending writes with err (even when err is falsy) and rejects pending and subsequent reads with err.

Unlike close, which completes readers normally, this propagates a producer error to consumers (next(), read(), maybeRead() and for await reject with err).

No-op if the channel is already closed for writing.

Reads the next value, returning undefined after channel completion.

When T includes undefined, a queued undefined value and channel completion have the same return value. Use next() and inspect done when that distinction matters.

Like write, resolving with false instead of rejecting (including on abort).

Registers callback to be called when channel has done writing. Callback is called immediatelly if channel is already closed for writing.

Pushes read to the channel.

Pushes write to the channel.

Writes value; resolves once a reader took it or it was buffered.

Aborting signal while the write is still blocked withdraws it — the value is never delivered — and rejects with signal.reason; a write that was already accepted is unaffected. A signal that is already aborted rejects without touching the channel.