Struct LimitCodec

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

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>

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

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

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

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