Struct distant_core::SessionChannel

pub struct SessionChannel { /* fields omitted */ }

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

Implementations

impl SessionChannel

pub fn is_closed(&self) -> bool

Returns true if no more requests can be transferred

pub async fn mail(&mut self, req: Request) -> Result<Mailbox, TransportError>

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 send(&mut self, req: Request) -> Result<Response, TransportError>

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: Request,
    duration: Duration
) -> Result<Response, TransportError>

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

pub async fn fire(&mut self, req: Request) -> Result<(), TransportError>

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: Request,
    duration: Duration
) -> Result<(), TransportError>

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

Trait Implementations

impl Clone for SessionChannel

fn clone(&self) -> SessionChannel

Returns a copy of the value.

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

Performs copy-assignment from source.

impl From<Session> for SessionChannel

fn from(session: Session) -> Self

Performs the conversion.