Struct OneshotSender

pub struct OneshotSender<T>(/* private fields */);

The sending half of a channel returned by oneshot.

Implementations

impl<T> OneshotSender<T>

pub fn send(self, value: T)

Sends value to the receiving endpoint of the channel.

pub fn is_closed(&self) -> bool

Returns true if the matching receiver is closed.

Trait Implementations

impl<T> Debug for OneshotSender<T>

fn fmt(&self, f: &mut Formatter<'_>) -> Result<(), Error>

Formats the value using the given formatter.

impl<T> DefaultEncoding for OneshotSender<T>

where T: MeshField,

type Encoding = PortField

The encoding to use for the serialization.

impl<T> From<OneshotSender<T>> for Port

where T: MeshField,

fn from(sender: OneshotSender<T>) -> Port

Converts to this type from the input type.

impl<T> From<Port> for OneshotSender<T>

where T: MeshField,

fn from(port: Port) -> OneshotSender<T>

Converts to this type from the input type.

impl<T> RpcSend for OneshotSender<T>

where T: 'static + Send,

type Message = T

The message type for this sender.

fn send_rpc(self, message: T)

Send an RPC request.

fn call<F, I, R>(self, f: F, input: I) -> PendingRpc<R>

where F: FnOnce(Rpc<I, R>) -> Self::Message, R: 'static + Send,

Issues a request and returns a channel to receive the result.

fn call_failable<F, I, T, E>(self, f: F, input: I) -> PendingFailableRpc<T, E>

where F: FnOnce(Rpc<I, Result<T, E>>) -> Self::Message, T: 'static + Send, E: 'static + Send,

Issues a request and returns an object to receive the result.