Struct distant_core::DistantServer

pub struct DistantServer { /* fields omitted */ }

Represents a server that listens for requests, processes them, and sends responses

Implementations

impl DistantServer

pub async fn bind(
    addr: IpAddr,
    port: PortRange,
    auth_key: Option<Arc<SecretKey>>,
    opts: DistantServerOptions
) -> Result<(Self, u16)>

Bind to an IP address and port from the given range, taking an optional shutdown duration that will shutdown the server if there is no active connection after duration

pub fn initialize<T, S>(stream: S, opts: DistantServerOptions) -> Self where
    T: DataStream + Send + 'static,
    S: Stream<Item = Transport<T>> + Send + Unpin + 'static, 

Initialize a distant server using the provided listener

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

Waits for the server to terminate

pub fn abort(&self)

Aborts the server by aborting the internal task handling new connections