pub(super) struct Encoder {
started: bool,
}Expand description
Writes the frames of one direction of a connection.
Fields§
§started: boolWhether the zlib header went out with the first header block.
Implementations§
Source§impl Encoder
impl Encoder
Sourcepub(super) fn encode(&mut self, frame: &Frame, buf: &mut BytesMut) -> Result<()>
pub(super) fn encode(&mut self, frame: &Frame, buf: &mut BytesMut) -> Result<()>
Append the encoded frame to the buffer.
fn control(buf: &mut BytesMut, typ: u16, fin: bool, len: usize)
fn put_len(buf: &mut BytesMut, len: usize)
Sourcefn header_block(&mut self, headers: &Headers) -> Vec<u8> ⓘ
fn header_block(&mut self, headers: &Headers) -> Vec<u8> ⓘ
Serialize a header block into stored deflate blocks, which every zlib decompressor reads like compressed ones. Compressing the blocks of the server would gain nothing, they are empty.
Sourcefn deflate(&mut self, raw: &[u8]) -> Vec<u8> ⓘ
fn deflate(&mut self, raw: &[u8]) -> Vec<u8> ⓘ
Wrap a serialized header block into stored deflate blocks, the first one of the connection with the zlib header.
Sourcefn stored_block(block: &mut Vec<u8>, data: &[u8])
fn stored_block(block: &mut Vec<u8>, data: &[u8])
A stored deflate block which is not the last one.
Trait Implementations§
Auto Trait Implementations§
impl Freeze for Encoder
impl RefUnwindSafe for Encoder
impl Send for Encoder
impl Sync for Encoder
impl Unpin for Encoder
impl UnsafeUnpin for Encoder
impl UnwindSafe for Encoder
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
impl<ST, DT> CastableFrom<ST, Initialized, Initialized> for DT
impl<ST, DT> CastableFrom<ST, Uninit, Uninit> for DT
§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> ⓘ
§impl<T> IntoRequest<T> for T
impl<T> IntoRequest<T> for T
§fn into_request(self) -> Request<T>
fn into_request(self) -> Request<T>
Wrap the input message
T in a tonic::Request§impl<L> LayerExt<L> for L
impl<L> LayerExt<L> for L
§fn named_layer<S>(&self, service: S) -> Layered<<L as Layer<S>>::Service, S>where
L: Layer<S>,
fn named_layer<S>(&self, service: S) -> Layered<<L as Layer<S>>::Service, S>where
L: Layer<S>,
Applies the layer to a service and wraps it in [
Layered].