Struct async_codec_lite::LimitCodec

pub struct LimitCodec<C: DecoderWithSkipAhead> { /* fields omitted */ }

Implementations

impl<C> LimitCodec<C> where
    C: DecoderWithSkipAhead, 

pub fn new(inner: C, max_frame_size: usize) -> Self

Trait Implementations

impl<C: Debug + DecoderWithSkipAhead> Debug for LimitCodec<C>

pub fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl<C> Decoder for LimitCodec<C> where
    C: DecoderWithSkipAhead, 

type Error = LimitError<<C as Decoder>::Error>

type Item = <C as Decoder>::Item

pub fn decode(
    &mut self,
    src: &mut BytesMut
) -> Result<Option<Self::Item>, Self::Error>

pub fn decode_eof(
    &mut self,
    src: &mut BytesMut
) -> Result<Option<Self::Item>, Self::Error>

impl<C> Encoder for LimitCodec<C> where
    C: Encoder + DecoderWithSkipAhead, 

type Error = LimitError<<C as Encoder>::Error>

type Item = <C as Encoder>::Item

pub fn encode(
    &mut self,
    src: Self::Item,
    dst: &mut BytesMut
) -> Result<(), Self::Error>