Struct Codec 

pub struct Codec { /* private fields */ }

Stateful HTTP/1 request decoder and response encoder.

The codec tracks the version, connection behavior, request method, and streaming state of the most recently decoded request.

Decoding

Decoder::decode incrementally consumes one request head and returns its Request together with a PayloadType. For PayloadType::Payload, pass subsequent bytes to the returned payload decoder until framing completes before decoding another request head. Bytes for a pipelined request can already remain in the input buffer. PayloadType::Stream ends HTTP message framing; transfer the connection and any buffered bytes to the upgraded protocol instead of decoding another HTTP request.

Ok(None) means that more bytes are required. A DecodeError indicates invalid framing or a configured request-head limit and should be treated as a connection-level protocol failure.

Encoding

Encoder::encode accepts a Message<(Response<()>, BodySize)>. Encode the response head first, followed by body chunks and a final Message::Chunk(None) when the response has a body. The codec selects fixed-length, chunked, or connection-close framing from the response, request method, version, and supplied BodySize. An EncodeError indicates invalid response encoding or an incomplete fixed-length body.

The codec only transforms buffers; it does not perform I/O, flush output, or apply transport backpressure.

Implementations

impl Codec

pub fn new(con_id: usize, cfg: Cfg<HttpServiceConfig>) -> Self

Creates an HTTP/1 codec.

con_id identifies the connection in decoded request heads. Protocol limits and keep-alive behavior are read from cfg.

pub fn keepalive(&self) -> bool

Returns whether the current HTTP connection state is persistent.

Before the first request is decoded, this reflects whether keep-alive is enabled in the service configuration. Decoding a request or encoding a response can update the value.

Trait Implementations

impl Clone for Codec

fn clone(&self) -> Self

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for Codec

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Decoder for Codec

type Item = (Request, PayloadType)

The type of decoded frames.

type Error = DecodeError

The type of unrecoverable frame decoding errors.

fn decode(&self, src: &mut BytesMut) -> Result<Option<Self::Item>, Self::Error>

Attempts to decode a frame from the buffered input.

fn decode_eof( &self, src: &mut BytesMut, ) -> Result<Option<Self::Item>, Self::Error>

Attempts to decode a frame once the transport reached a clean EOF.

impl Encoder for Codec

type Item = Message<(Response<()>, BodySize)>

The type of frames consumed by the encoder.

type Error = EncodeError

The type of encoding errors.

fn encode( &self, item: Self::Item, dst: &mut BytePages, ) -> Result<(), Self::Error>

Encodes a frame and appends it to dst.