Struct distant_core::RelayServer

pub struct RelayServer { /* fields omitted */ }

Represents a server that relays requests & responses between connections and the actual server

Implementations

impl RelayServer

pub fn initialize<T1, T2, S>(
    session: Session<T1>,
    stream: S,
    shutdown_after: Option<Duration>
) -> Result<Self> where
    T1: DataStream + 'static,
    T2: DataStream + Send + 'static,
    S: Stream<Item = Transport<T2>> + Send + Unpin + 'static, 

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

Waits for the server to terminate

pub async fn abort(&self)

Aborts the server by aborting the internal tasks and current connections