Struct distant_core::Session

pub struct Session { /* fields omitted */ }

Represents a session with a remote server that can be used to send requests & receive responses

Implementations

impl Session

pub async fn tcp_connect<U>(addr: SocketAddr, codec: U) -> Result<Self> where
    U: Codec + Send + 'static, 

Connect to a remote TCP server using the provided information

pub async fn tcp_connect_timeout<U>(
    addr: SocketAddr,
    codec: U,
    duration: Duration
) -> Result<Self> where
    U: Codec + Send + 'static, 

Connect to a remote TCP server, timing out after duration has passed

impl Session

pub async fn unix_connect<U>(path: impl AsRef<Path>, codec: U) -> Result<Self> where
    U: Codec + Send + 'static, 

Connect to a proxy unix socket

pub async fn unix_connect_timeout<U>(
    path: impl AsRef<Path>,
    codec: U,
    duration: Duration
) -> Result<Self> where
    U: Codec + Send + 'static, 

Connect to a proxy unix socket, timing out after duration has passed

impl Session

pub fn initialize<T, U>(transport: Transport<T, U>) -> Result<Self> where
    T: DataStream,
    U: Codec + Send + 'static, 

Initializes a session using the provided transport

impl Session

pub async fn wait(self) -> Result<(), JoinError>

Waits for the session to terminate, which results when the receiving end of the network connection is closed (or the session is shutdown)

pub fn abort(&self)

Abort the session’s current connection by forcing its response task to shutdown

pub fn clone_channel(&self) -> SessionChannel

Clones the underlying channel for requests and returns the cloned instance

Trait Implementations

impl Deref for Session

type Target = SessionChannel

The resulting type after dereferencing.

fn deref(&self) -> &Self::Target

Dereferences the value.

impl DerefMut for Session

fn deref_mut(&mut self) -> &mut Self::Target

Mutably dereferences the value.