Struct distant_core::TransportListener

pub struct TransportListener<T> where
    T: DataStream,  { /* fields omitted */ }

Represents a [Stream] consisting of newly-connected DataStream instances that have been wrapped in Transport

Implementations

impl<T> TransportListener<T> where
    T: DataStream + Send + 'static, 

pub fn initialize<L>(listener: L, ctx: TransportListenerCtx) -> Self where
    L: Listener<Output = T> + 'static, 

pub fn abort(&self)

pub async fn accept(&mut self) -> Option<Transport<T>>

Waits for the next fully-initialized transport for an incoming stream to be available, returning none if no longer accepting new connections

pub fn into_stream(self) -> impl Stream<Item = Transport<T>>

Converts into a stream of transport-wrapped connections