pub struct LengthDelimitedFramer;
Expand description
Frames incoming data by splitting data based on a fixed-size length delimiter.
All frames are prepended with a 4-byte integer, in little endian order, which indicates how much additional data is included in the frame. This framer only supports frame lengths that fit within the given buffer, which is to say that if the length described in the delimiter would exceed the current buffer, it is considered an invalid frame.
Trait Implementations§
Source§impl Default for LengthDelimitedFramer
impl Default for LengthDelimitedFramer
Source§fn default() -> LengthDelimitedFramer
fn default() -> LengthDelimitedFramer
Returns the “default value” for a type. Read more
Source§impl Framer for LengthDelimitedFramer
impl Framer for LengthDelimitedFramer
Source§fn next_frame<B: ReadIoBuffer>(
&mut self,
buf: &mut B,
is_eof: bool,
) -> Result<Option<Bytes>, FramingError>
fn next_frame<B: ReadIoBuffer>( &mut self, buf: &mut B, is_eof: bool, ) -> Result<Option<Bytes>, FramingError>
Attempt to extract the next frame from the buffer. Read more
Auto Trait Implementations§
impl Freeze for LengthDelimitedFramer
impl RefUnwindSafe for LengthDelimitedFramer
impl Send for LengthDelimitedFramer
impl Sync for LengthDelimitedFramer
impl Unpin for LengthDelimitedFramer
impl UnwindSafe for LengthDelimitedFramer
Blanket Implementations§
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
Mutably borrows from an owned value. Read more
Source§impl<T> Instrument for T
impl<T> Instrument for T
Source§fn instrument(self, span: Span) -> Instrumented<Self>
fn instrument(self, span: Span) -> Instrumented<Self>
Source§fn in_current_span(self) -> Instrumented<Self>
fn in_current_span(self) -> Instrumented<Self>
Source§impl<T> IntoRequest<T> for T
impl<T> IntoRequest<T> for T
Source§fn into_request(self) -> Request<T>
fn into_request(self) -> Request<T>
Wrap the input message
T
in a tonic::Request
Source§impl<T> Pointable for T
impl<T> Pointable for T
Source§impl<T> Track for T
impl<T> Track for T
Source§fn track_allocations(self, token: AllocationGroupToken) -> Tracked<Self>
fn track_allocations(self, token: AllocationGroupToken) -> Tracked<Self>
Instruments this type by attaching the given allocation group token, returning a
Tracked
wrapper. Read moreSource§fn in_current_allocation_group(self) -> Tracked<Self>
fn in_current_allocation_group(self) -> Tracked<Self>
Instruments this type by attaching the current allocation group, returning a
Tracked
wrapper. Read more