minghuaw / fe2o3-amqp

A rust implementation of the AMQP1.0 protocol based on serde and tokio.

MIT License

64 stars 7 forks source link

Do not consume src buffer before decoding succeeds #272

Closed minghuaw closed 1 month ago

minghuaw commented 3 months ago

270

minghuaw commented 1 month ago

This is fine in the case of the FrameDecoder because we have a LengthDelimitedCodec that already ensures a complete frame is received before attempting to decode it.