Struct LengthDelimitedCodec
pub struct LengthDelimitedCodec { /* private fields */ }
Expand description
A codec for frames delimited by a frame head specifying their lengths.
This allows the consumer to work with entire frames without having to worry about buffering or other framing logic.
See module level documentation for more detail.
Implementations§
§impl LengthDelimitedCodec
impl LengthDelimitedCodec
pub fn new() -> LengthDelimitedCodec
pub fn new() -> LengthDelimitedCodec
Creates a new LengthDelimitedCodec
with the default configuration values.
pub fn builder() -> Builder
pub fn builder() -> Builder
Creates a new length delimited codec builder with default configuration values.
pub fn max_frame_length(&self) -> usize
pub fn max_frame_length(&self) -> usize
Returns the current max frame setting
This is the largest size this codec will accept from the wire. Larger frames will be rejected.
pub fn set_max_frame_length(&mut self, val: usize)
pub fn set_max_frame_length(&mut self, val: usize)
Updates the max frame setting.
The change takes effect the next time a frame is decoded. In other
words, if a frame is currently in process of being decoded with a frame
size greater than val
but less than the max frame length in effect
before calling this function, then the frame will be allowed.
Trait Implementations§
§impl Clone for LengthDelimitedCodec
impl Clone for LengthDelimitedCodec
§fn clone(&self) -> LengthDelimitedCodec
fn clone(&self) -> LengthDelimitedCodec
1.0.0 · Source§fn clone_from(&mut self, source: &Self)
fn clone_from(&mut self, source: &Self)
source
. Read more§impl Debug for LengthDelimitedCodec
impl Debug for LengthDelimitedCodec
§impl Decoder for LengthDelimitedCodec
impl Decoder for LengthDelimitedCodec
§fn decode(&mut self, src: &mut BytesMut) -> Result<Option<BytesMut>, Error>
fn decode(&mut self, src: &mut BytesMut) -> Result<Option<BytesMut>, Error>
§impl Default for LengthDelimitedCodec
impl Default for LengthDelimitedCodec
§fn default() -> LengthDelimitedCodec
fn default() -> LengthDelimitedCodec
Auto Trait Implementations§
impl Freeze for LengthDelimitedCodec
impl RefUnwindSafe for LengthDelimitedCodec
impl Send for LengthDelimitedCodec
impl Sync for LengthDelimitedCodec
impl Unpin for LengthDelimitedCodec
impl UnwindSafe for LengthDelimitedCodec
Blanket Implementations§
§impl<'a, T, E> AsTaggedExplicit<'a, E> for Twhere
T: 'a,
impl<'a, T, E> AsTaggedExplicit<'a, E> for Twhere
T: 'a,
§impl<'a, T, E> AsTaggedImplicit<'a, E> for Twhere
T: 'a,
impl<'a, T, E> AsTaggedImplicit<'a, E> for Twhere
T: 'a,
Source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
Source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Source§impl<T> CloneToUninit for Twhere
T: Clone,
impl<T> CloneToUninit for Twhere
T: Clone,
§impl<T> FutureExt for T
impl<T> FutureExt for T
§fn with_context(self, otel_cx: Context) -> WithContext<Self> ⓘ
fn with_context(self, otel_cx: Context) -> WithContext<Self> ⓘ
§fn with_current_context(self) -> WithContext<Self> ⓘ
fn with_current_context(self) -> WithContext<Self> ⓘ
§impl<T> Instrument for T
impl<T> Instrument for T
§fn instrument(self, span: Span) -> Instrumented<Self> ⓘ
fn instrument(self, span: Span) -> Instrumented<Self> ⓘ
§fn in_current_span(self) -> Instrumented<Self> ⓘ
fn in_current_span(self) -> Instrumented<Self> ⓘ
Source§impl<T> IntoEither for T
impl<T> IntoEither for T
Source§fn into_either(self, into_left: bool) -> Either<Self, Self> ⓘ
fn into_either(self, into_left: bool) -> Either<Self, Self> ⓘ
self
into a Left
variant of Either<Self, Self>
if into_left
is true
.
Converts self
into a Right
variant of Either<Self, Self>
otherwise. Read moreSource§fn into_either_with<F>(self, into_left: F) -> Either<Self, Self> ⓘ
fn into_either_with<F>(self, into_left: F) -> Either<Self, Self> ⓘ
self
into a Left
variant of Either<Self, Self>
if into_left(&self)
returns true
.
Converts self
into a Right
variant of Either<Self, Self>
otherwise. Read more§impl<T> Pointable for T
impl<T> Pointable for T
§impl<T> PolicyExt for Twhere
T: ?Sized,
impl<T> PolicyExt for Twhere
T: ?Sized,
§fn and<P, B, E>(self, other: P) -> And<T, P>
fn and<P, B, E>(self, other: P) -> And<T, P>
Policy
that returns Action::Follow
only if self
and other
return
Action::Follow
. Read more