From 913a849cdf8957f372570396ff21954bfc753717 Mon Sep 17 00:00:00 2001 From: Ondrej Babec Date: Thu, 14 Apr 2022 16:54:12 +0200 Subject: [PATCH] Propagate buffer failure5 --- mqtt/src/client/client.rs | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/mqtt/src/client/client.rs b/mqtt/src/client/client.rs index 8362ddd..6098321 100644 --- a/mqtt/src/client/client.rs +++ b/mqtt/src/client/client.rs @@ -473,7 +473,7 @@ async fn receive_packet<'c, T:NetworkConnection>(buffer: & mut [u8],buffer_len: let len: usize = conn.receive(recv_buffer).await?; if len > 0 { trace!("Received len: {}", len); - if Err(e) = writer.insert_ref(len, &recv_buffer) { + if let Err(e) = writer.insert_ref(len, &recv_buffer) { error!("Buffer operation failed with: {}", e); return Err(ReasonCode::BuffError); }