pub struct FlexBuf { /* private fields */ }
Expand description
FlexBuf is a buffer that support frozen bytes and reuse existing allocated memory.
It’s useful when we want to freeze the buffer and reuse the memory for the next buffer.
Implementations§
Source§impl FlexBuf
impl FlexBuf
Sourcepub fn put(&mut self, bs: &[u8]) -> usize
pub fn put(&mut self, bs: &[u8]) -> usize
Put slice into flex buf.
Return 0 means the buffer is frozen.
Sourcepub fn freeze(&mut self)
pub fn freeze(&mut self)
Freeze the buffer no matter it’s full or not.
It’s a no-op if the buffer has already been frozen.
Auto Trait Implementations§
impl !Freeze for FlexBuf
impl RefUnwindSafe for FlexBuf
impl Send for FlexBuf
impl Sync for FlexBuf
impl Unpin for FlexBuf
impl UnwindSafe for FlexBuf
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> PolicyExt for Twhere
T: ?Sized,
impl<T> PolicyExt for Twhere
T: ?Sized,
Source§impl<T> ServiceExt for T
impl<T> ServiceExt for T
Source§fn map_response_body<F>(self, f: F) -> MapResponseBody<Self, F>where
Self: Sized,
fn map_response_body<F>(self, f: F) -> MapResponseBody<Self, F>where
Self: Sized,
Apply a transformation to the response body. Read more
Source§fn decompression(self) -> Decompression<Self>where
Self: Sized,
fn decompression(self) -> Decompression<Self>where
Self: Sized,
Decompress response bodies. Read more
Source§fn trace_for_http(self) -> Trace<Self, SharedClassifier<ServerErrorsAsFailures>>where
Self: Sized,
fn trace_for_http(self) -> Trace<Self, SharedClassifier<ServerErrorsAsFailures>>where
Self: Sized,
High level tracing that classifies responses using HTTP status codes. Read more
Source§fn trace_for_grpc(self) -> Trace<Self, SharedClassifier<GrpcErrorsAsFailures>>where
Self: Sized,
fn trace_for_grpc(self) -> Trace<Self, SharedClassifier<GrpcErrorsAsFailures>>where
Self: Sized,
High level tracing that classifies responses using gRPC headers. Read more