Struct remoc::chmux::ChMux

pub struct ChMux<TransportSink, TransportStream> { /* private fields */ }

Channel multiplexer.

Implementations

impl<TransportSink, TransportSinkError, TransportStream, TransportStreamError> ChMux<TransportSink, TransportStream>

where TransportSink: Sink<Bytes, Error = TransportSinkError> + Send + Unpin, TransportSinkError: Error + Send + Sync + 'static, TransportStream: Stream<Item = Result<Bytes, TransportStreamError>> + Send + Unpin, TransportStreamError: Error + Send + Sync + 'static,

pub async fn new( cfg: Cfg, transport_sink: TransportSink, transport_stream: TransportStream ) -> Result<(Self, Client, Listener), ChMuxError<TransportSinkError, TransportStreamError>>

Creates a new multiplexer.

After creation use the run method of the multiplexer to launch the dispatch task.

Panics

Panics if specified configuration does not obey limits documented in Cfg.

pub async fn run( self ) -> Result<(), ChMuxError<TransportSinkError, TransportStreamError>>

Runs the multiplexer dispatcher.

The dispatcher terminates when the client, server and all channels have been dropped or the transport is closed.

Trait Implementations

impl<TransportSink, TransportStream> Debug for ChMux<TransportSink, TransportStream>

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

Formats the value using the given formatter.

impl<TransportSink, TransportStream> Drop for ChMux<TransportSink, TransportStream>

fn drop(&mut self)

Executes the destructor for this type.