Noratrieb/haesli
1
0
Fork 0
mirror of https://github.com/Noratrieb/haesli.git synced 2026-01-16 20:55:03 +01:00
Code Issues Projects Releases Packages Wiki Activity Actions

parse frame payload

Browse source
This commit is contained in:
nora 2022-02-09 14:51:44 +01:00
parent 706219c046
commit ccee6c36f6
3 changed files with 55 additions and 33 deletions
Download patch file Download diff file Expand all files Collapse all files

6
amqp_transport/src/connection.rs
View file

@ -1,4 +1,4 @@
use crate::error::{ConError, ProtocolError};
use crate::error::{ProtocolError, TransError};
use crate::frame;
use anyhow::{ensure, Context};
use tokio::io::{AsyncReadExt, AsyncWriteExt};
@ -21,7 +21,7 @@ impl Connection {
}
}
pub async fn run(&mut self) -> Result<(), ConError> {
pub async fn run(&mut self) -> Result<(), TransError> {
self.negotiate_version().await?;
loop {
@ -30,7 +30,7 @@ impl Connection {
}
}
async fn negotiate_version(&mut self) -> Result<(), ConError> {
async fn negotiate_version(&mut self) -> Result<(), TransError> {
const HEADER_SIZE: usize = 8;
const PROTOCOL_VERSION: &[u8] = &[0, 9, 1];
const PROTOCOL_HEADER: &[u8] = b"AMQP\0\0\x09\x01";