Sender

import { Sender } from "destack:channel";

Synchronous sender endpoint.

export interface Sender<T> {
    send(value: ^T): Result<void, SendError<T>>;
    trySend(value: ^T): Result<void, SendError<T>>;
    close(): void;
}
language/library/src/channel/channel.ds:62:71

Members

send(value: ^T): Result<void, SendError<T>>

Send one value.

trySend(value: ^T): Result<void, SendError<T>>

Try to send one value without blocking.

close(): void

Close this sender.