Struct lapin_futures_openssl::lapin::transport::AMQPCodec
pub struct AMQPCodec {
pub frame_max: u32,
}
Expand description
implements tokio-io’s Decoder and Encoder
Fields§
§frame_max: u32
Trait Implementations§
§impl Decoder for AMQPCodec
impl Decoder for AMQPCodec
§fn decode(&mut self, buf: &mut BytesMut) -> Result<Option<AMQPFrame>, Error>
fn decode(&mut self, buf: &mut BytesMut) -> Result<Option<AMQPFrame>, Error>
Attempts to decode a frame from the provided buffer of bytes. Read more