Struct remoc::rch::base::Sender

pub struct Sender<T, Codec = Default> { /* private fields */ }

Available on crate feature rch only.

Sends arbitrary values to a remote endpoint.

Values may be or contain any channel from this crate.

Implementations

impl<T, Codec> Sender<T, Codec>

where T: Serialize + Send + 'static, Codec: Codec,

pub fn new(sender: Sender) -> Self

Creates a base remote sender from a chmux sender.

pub async fn send(&mut self, item: T) -> Result<(), SendError<T>>

Sends an item over the channel.

The item may contain ports that will be serialized and connected as well.

pub fn is_closed(&self) -> bool

True, once the remote endpoint has closed its receiver.

pub fn closed(&self) -> Closed

Returns a future that will resolve when the remote endpoint closes its receiver.

pub fn max_item_size(&self) -> usize

The maximum allowed size in bytes of an item to be sent.

The default value is DEFAULT_MAX_ITEM_SIZE.

pub fn set_max_item_size(&mut self, max_item_size: usize)

Sets the maximum allowed size in bytes of an item to be sent.

This does not change the maximum allowed size on the receive end. Thus if the maximum allowed size is larger on the sender than on the receiver, sending of oversized items will succeed but the receiver will fail with a MaxItemSizeExceeded error when trying to receive the item.

Trait Implementations

impl<T, Codec> Debug for Sender<T, Codec>

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

Formats the value using the given formatter.