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<T, U, S>(
    session: Session,
    stream: S,
    shutdown_after: Option<Duration>
) -> Result<Self> where
    T: DataStream + Send + 'static,
    U: Codec + Send + 'static,
    S: Stream<Item = Transport<T, U>> + 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