Struct divans::mux::Mux

pub struct Mux<AllocU8: Allocator<u8>> { /* fields omitted */ }

Methods

impl<AllocU8: Allocator<u8>> Mux<AllocU8>

pub fn read_cursor(&self, index: usize) -> usize

pub fn write_cursor(&self, index: usize) -> usize

impl<AllocU8: Allocator<u8>> Mux<AllocU8>

pub fn how_much_data_avail(&self, stream_id: StreamID) -> usize

Important traits for &'a [u8]

impl<'a> Read for &'a [u8]impl<'a> Write for &'a mut [u8]

pub fn data_avail(&self, stream_id: StreamID) -> &[u8]

pub fn consume_data(&mut self, stream_id: StreamID, count: usize)

pub fn is_eof(&self) -> bool

pub fn prealloc(&mut self, m8: &mut AllocU8, amount_per_stream: usize)

pub fn free(&mut self, m8: &mut AllocU8)

pub fn push_data(&mut self, stream_id: StreamID, data: &[u8], m8: &mut AllocU8)

pub fn prep_push_for_n_bytes(     &mut self,     stream_id: StreamID,     data_len: usize,     m8: &mut AllocU8 ) -> (&mut AllocU8::AllocatedMemory, &mut usize)

pub fn deserialize_eof(&mut self, input: &[u8]) -> usize

pub fn deserialize(&mut self, input: &[u8], m8: &mut AllocU8) -> usize

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

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

Trait Implementations

impl<AllocU8: Allocator<u8>> Default for Mux<AllocU8>

fn default() -> Self

Returns the "default value" for a type.

impl<AllocU8: Allocator<u8>> StreamDemuxer<AllocU8> for Mux<AllocU8>

fn write_linear(&mut self, data: &[u8], m8: &mut AllocU8) -> usize

fn read_buffer(&mut self) -> [ReadableBytes; 2]

fn data_ready(&self, stream_id: StreamID) -> usize

Important traits for &'a [u8]

impl<'a> Read for &'a [u8]impl<'a> Write for &'a mut [u8]

fn peek(&self, stream_id: StreamID) -> &[u8]

fn edit(     &mut self,     stream_id: StreamID ) -> &mut AllocatedMemoryRange<u8, AllocU8>

fn consume(&mut self, stream_id: StreamID, count: usize)

fn consumed_all_streams_until_eof(&self) -> bool

fn encountered_eof(&self) -> bool

fn free_demux(&mut self, m8: &mut AllocU8)

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

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

fn write_buffer(&mut self, m8: &mut AllocU8) -> [WritableBytes; 2]

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

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

fn wrote_eof(&self) -> bool

fn free_mux(&mut self, m8: &mut AllocU8)

fn can_linearize() -> bool