Struct Decoder 

pub(super) struct Decoder {
    decompress: Decompress,
    partial_data: Option<(u32, usize, bool)>,
}

Reads the frames of one direction of a connection.

Fields

decompress: Decompress

partial_data: Option<(u32, usize, bool)>

The data frame which is handed out in parts: its stream, the bytes still to read and its FIN flag.

Implementations

impl Decoder

pub(super) async fn read<R>(&mut self, reader: &mut R) -> Result<Option<Frame>>

where R: AsyncRead + Unpin,

Read the next frame, None if the connection ended in between frames. A data frame larger than DATA_CHUNK_LEN comes as several ones of the same stream, only the last one with its FIN flag.

async fn read_data<R>( &mut self, reader: &mut R, stream_id: u32, remaining: usize, fin: bool, ) -> Result<Frame>

where R: AsyncRead + Unpin,

Read a data frame, or the next part of a large one.

fn decode( &mut self, header: [u8; 8], flags: u8, payload: Bytes, ) -> Result<Frame>

Decode a control frame from its header and complete payload.

fn header_block(&mut self, input: &[u8]) -> Result<Headers>

Decompress and parse a header block.

fn parse_header_block(block: &[u8]) -> Result<Headers>

Trait Implementations

impl Default for Decoder

fn default() -> Self

Returns the “default value” for a type.