menu

Sender

import { Sender } from "destack:channel";

Synchronous sender endpoint.

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

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.