Struct turbulence::packet_multiplexer::PacketMultiplexer

pub struct PacketMultiplexer<P> { /* fields omitted */ }

Routes packets marked with a channel header from a single Sink / Stream pair to a set of Sink / Stream pairs for each channel.

Also monitors bandwidth on each channel independently, and returns a ChannelStatistics handle to query bandwidth totals for that specific channel.

Implementations

impl<P> PacketMultiplexer<P> where
    P: Packet + Unpin, 

pub fn new() -> PacketMultiplexer<P>

pub fn open_channel(
    &mut self,
    channel: PacketChannel,
    buffer_size: usize
) -> Result<(Sender<MuxPacket<P>>, Receiver<MuxPacket<P>>, ChannelStatistics), DuplicateChannel>

Open a multiplexed packet channel, producing a sender for outgoing MuxPackets on this channel, and a receiver for incoming MuxPackets on this channel.

The buffer_size parameter controls the buffer size requested when creating the MPSC futures channels for the returned Sender and Receiver.

pub fn start(
    self
) -> (IncomingMultiplexedPackets<P>, OutgoingMultiplexedPackets<P>)

Start multiplexing packets to all opened channels.

Returns an IncomingMultiplexedPackets which is a Sink for incoming packets, and an OutgoingMultiplexedPackets which is a Stream for outgoing packets.