fix(codecs): Continue on error

This reverts a commit to bump tokio-util from 0.6.8 to 0.6.9 (#9938) since this introduced behavior where Vector would stop processing if the incoming data couldn't be parsed by the codec. This reverts commit d6ace26. Closes: #11245
vectordotdev · Feb 8, 2022 · f5573ca · f5573ca
1 parent 1a7bf03
commit f5573ca
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 2 deletions.
diff --git a/Cargo.lock b/Cargo.lock
diff --git a/src/expiring_hash_map.rs b/src/expiring_hash_map.rs
@@ -244,6 +244,7 @@ mod tests {
         let mut map = ExpiringHashMap::<String, String>::default();
 
         map.insert("key".to_owned(), "val".to_owned(), Duration::from_secs(1));
+        map.remove("key");
 
         let mut fut = task::spawn(map.next_expired());
         assert_pending!(fut.poll());