Struct UntypedChannel

pub struct UntypedChannel { /* private fields */ }

Represents a sender of requests tied to a session, holding onto a weak reference of mailboxes to relay responses, meaning that once the Client is closed or dropped, any sent request will no longer be able to receive responses.

In contrast to Channel, this implementation is untyped, meaning that the payload of requests and responses are not validated.

Implementations

impl UntypedChannel

pub fn is_closed(&self) -> bool

Returns true if no more requests can be transferred

pub fn into_typed_channel<T, U>(self) -> Channel<T, U>

Consumes this channel, returning a typed variant

pub async fn assign_default_mailbox( &self, buffer: usize, ) -> Result<Mailbox<UntypedResponse<'static>>>

Assigns a default mailbox for any response received that does not match another mailbox.

pub async fn remove_default_mailbox(&self) -> Result<()>

Removes the default mailbox used for unmatched responses such that any response without a matching mailbox will be dropped.

pub async fn mail( &mut self, req: UntypedRequest<'_>, ) -> Result<Mailbox<UntypedResponse<'static>>>

Sends a request and returns a mailbox that can receive one or more responses, failing if unable to send a request or if the session’s receiving line to the remote server has already been severed

pub async fn mail_timeout( &mut self, req: UntypedRequest<'_>, duration: impl Into<Option<Duration>>, ) -> Result<Mailbox<UntypedResponse<'static>>>

Sends a request and returns a mailbox, timing out after duration has passed

pub async fn send( &mut self, req: UntypedRequest<'_>, ) -> Result<UntypedResponse<'static>>

Sends a request and waits for a response, failing if unable to send a request or if the session’s receiving line to the remote server has already been severed

pub async fn send_timeout( &mut self, req: UntypedRequest<'_>, duration: impl Into<Option<Duration>>, ) -> Result<UntypedResponse<'static>>

Sends a request and waits for a response, timing out after duration has passed

pub async fn fire(&mut self, req: UntypedRequest<'_>) -> Result<()>

Sends a request without waiting for a response; this method is able to be used even if the session’s receiving line to the remote server has been severed

pub async fn fire_timeout( &mut self, req: UntypedRequest<'_>, duration: impl Into<Option<Duration>>, ) -> Result<()>

Sends a request without waiting for a response, timing out after duration has passed

Trait Implementations

impl Clone for UntypedChannel

fn clone(&self) -> Self

Returns a duplicate of the value.

const fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for UntypedChannel

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

Formats the value using the given formatter.

impl From<UntypedClient> for UntypedChannel

fn from(client: UntypedClient) -> Self

Converts to this type from the input type.