Trait lepton_mux::StreamMuxer

pub trait StreamMuxer<AllocU8: Allocator<u8>> {
    fn write(
        &mut self, 
        stream_id: StreamID, 
        data: &[u8], 
        alloc_u8: &mut AllocU8
    ) -> usize;
    fn write_buffer(
        &mut self, 
        stream_id: StreamID, 
        alloc_u8: &mut AllocU8
    ) -> WritableBytes;
    fn serialize(&mut self, output: &mut [u8]) -> usize;
    fn flush(&mut self, output: &mut [u8]) -> usize;
    fn wrote_eof(&self) -> bool;
    fn free(&mut self, alloc_u8: &mut AllocU8);
    fn n_stream(&self) -> usize;

    fn can_serialize() -> bool { ... }
}

Required Methods

fn write(
    &mut self,
    stream_id: StreamID,
    data: &[u8],
    alloc_u8: &mut AllocU8
) -> usize

Writes data to the specified stream.

fn write_buffer(
    &mut self,
    stream_id: StreamID,
    alloc_u8: &mut AllocU8
) -> WritableBytes

Returns an array of n_stream WritableBytes. Each WritableByte is connected to the buffer of its corresponding stream.

fn serialize(&mut self, output: &mut [u8]) -> usize

Populate output with content buffered by each stream in a "fair" manner.

fn flush(&mut self, output: &mut [u8]) -> usize

fn wrote_eof(&self) -> bool

fn free(&mut self, alloc_u8: &mut AllocU8)

fn n_stream(&self) -> usize

Provided Methods

fn can_serialize() -> bool

Implementors

• impl<AllocU8: Allocator<u8>> StreamMuxer<AllocU8> for Mux<AllocU8>

• impl<AllocU8: Allocator<u8>> StreamMuxer<AllocU8> for DevNull<AllocU8>