Update lib/codecs/src/decoding/framing/chunked_gelf.rs

Co-authored-by: Jesse Szwedko <jesse@szwedko.me>
vectordotdev · Oct 18, 2024 · f1e5996 · f1e5996
1 parent b214fdb
commit f1e5996
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/lib/codecs/src/decoding/framing/chunked_gelf.rs b/lib/codecs/src/decoding/framing/chunked_gelf.rs
@@ -243,7 +243,7 @@ impl ChunkedGelfDecoder {
             let timeout = self.timeout;
             let timeout_handle = tokio::spawn(async move {
                 tokio::time::sleep(timeout).await;
-                let mut state_lock = state.lock().unwrap();
+                let mut state_lock = state.lock().expect("poisoned lock");
                 if state_lock.remove(&message_id).is_some() {
                     warn!(
                         message_id = message_id,