Struct remoc::chmux::Listener

pub struct Listener { /* private fields */ }

Multiplexer listener.

Implementations

impl Listener

pub fn port_allocator(&self) -> PortAllocator

Obtains the port allocator.

pub async fn accept(
    &mut self
) -> Result<Option<(Sender, Receiver)>, ListenerError>

Accept a connection returning the sender and receiver for the opened port.

Returns None when the client of the remote endpoint has been dropped and no more connection requests can be made.

pub async fn inspect(&mut self) -> Result<Option<Request>, ListenerError>

Obtains the next connection request from the remote endpoint.

Connection requests can be stored and accepted or rejected at a later time. The maximum number of unanswered connection requests is specified in the configuration. If this number is reached, the remote endpoint will not send any more connection requests.

Returns None when the client of the remote endpoint has been dropped and no more connection requests can be made.

pub fn into_stream(self) -> ListenerStream

Convert this into a listener stream.

pub fn terminate(&self)

Terminates the multiplexer, forcibly closing all open ports.

Trait Implementations

impl Debug for Listener

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Drop for Listener

fn drop(&mut self)

Executes the destructor for this type.