AsyncReceiver

import { AsyncReceiver } from "destack:channel";

Asynchronous receiver endpoint.

export interface AsyncReceiver<T> {
    receive(): AsyncResult<T, ReceiveError>;
    tryReceive(): Result<T, ReceiveError>;
    close(): void;
}
language/library/src/channel/channel.ds:98:107

Members

receive(): AsyncResult<T, ReceiveError>

Receive one value.

tryReceive(): Result<T, ReceiveError>

Try to receive one value without suspending.

close(): void

Close this receiver.