pub struct NewlineFramer { /* private fields */ }
Expand description
Frames incoming data by splitting on newlines.
Only the newline character (0x0A, also known as “line feed”) is used to split the payload into frames. If there are carriage return characters (0x0D) in the payload, they will be included in the resulting frames.
Implementations§
Source§impl NewlineFramer
impl NewlineFramer
Sourcepub fn required_on_eof(self, require: bool) -> Self
pub fn required_on_eof(self, require: bool) -> Self
Whether or not the delimiter is required when EOF has been reached.
This controls whether or not the frames must always be suffixed by the delimiter character. In some cases, a delimiter is purely for separating multiple frames within a single payload, and when the final payload is sent, it may not include the delimiter at the end.
If the framing configuration requires the delimiter to always be present, then set this to true
.
Defaults to false
.
Trait Implementations§
Source§impl Default for NewlineFramer
impl Default for NewlineFramer
Source§fn default() -> NewlineFramer
fn default() -> NewlineFramer
Returns the “default value” for a type. Read more
Source§impl Framer for NewlineFramer
impl Framer for NewlineFramer
Source§fn next_frame<'a, B: ReadIoBuffer>(
&mut self,
buf: &mut B,
is_eof: bool,
) -> Result<Option<Bytes>, FramingError>
fn next_frame<'a, 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 NewlineFramer
impl RefUnwindSafe for NewlineFramer
impl Send for NewlineFramer
impl Sync for NewlineFramer
impl Unpin for NewlineFramer
impl UnwindSafe for NewlineFramer
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