Struct FrameCodec 

pub struct FrameCodec { /* private fields */ }

基于 length_codec 的帧解码器，用于读取 Python 的 stdout。

对于完整但非法的帧（JSON 错误、未知消息类型、字段缺失），解码结果为 Ok(Err(_))： 此时数据流仍对齐在帧边界上，可以继续读取。Err(_) 是致命错误，其中包括长度前缀超限时的 ProtocolError::TooLarge：双方在发送前都会检查大小，出现超限帧说明对端已损坏，因此不跳过。

Implementations

impl FrameCodec

pub fn new(max_frame_size: usize) -> Self

创建帧长上限为 max_frame_size 的解码器。

Trait Implementations

impl Decoder for FrameCodec

type Item = Result<Frame, ProtocolError>

The type of decoded frames.

type Error = ProtocolError

The type of unrecoverable frame decoding errors.

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

Attempts to decode a frame from the provided buffer of bytes.

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

A default method available to be called when there are no more bytes available to be read from the underlying I/O.

fn framed<T>(self, io: T) -> Framed<T, Self>

where T: AsyncRead + AsyncWrite, Self: Sized,

Provides a Stream and Sink interface for reading and writing to this Io object, using Decode and Encode to read and write the raw data.