Struct Muxer 

pub struct Muxer<E: Spawner, S: Sender, R: Receiver> { /* private fields */ }

A multiplexer of p2p channels into subchannels.

Implementations

impl<E: Spawner, S: Sender, R: Receiver> Muxer<E, S, R>

pub fn new( context: E, sender: S, receiver: R, mailbox_size: usize, ) -> (Self, MuxHandle<S, R>)

Create a multiplexed wrapper around a Sender and Receiver pair, and return a (Muxer, MuxHandle) pair that can be used to register routes dynamically.

pub fn builder( context: E, sender: S, receiver: R, mailbox_size: usize, ) -> MuxerBuilder<E, S, R>

Creates a MuxerBuilder that can be used to configure and build a Muxer.

pub fn start(self) -> Handle<Result<(), R::Error>>

Start the demuxer using the given spawner.

pub async fn run(self) -> Result<(), R::Error>

Drive demultiplexing of messages into per-subchannel receivers.

Callers should run this in a background task for as long as the underlying Receiver is expected to receive traffic.