Receiver

import { Receiver } from "destack:channel";

Synchronous receiver endpoint.

export interface Receiver<T> {
    receive(): Result<T, ReceiveError>;
    tryReceive(): Result<T, ReceiveError>;
    close(): void;
}
language/library/src/channel/channel.ds:74:83

Members

receive(): Result<T, ReceiveError>

Receive one value.

tryReceive(): Result<T, ReceiveError>

Try to receive one value without blocking.

close(): void

Close this receiver.