diff --git a/util/fastcdc.rs b/util/fastcdc.rs
index f220b9128..3cd572a57 100644
--- a/util/fastcdc.rs
+++ b/util/fastcdc.rs
@@ -4,7 +4,7 @@
// This implementation is heavily based on:
// https://github.com/nlfiedler/fastcdc-rs/blob/1e804fe27444e37b2c4f93d540f861d170c8a257/src/lib.rs
-use bytes::BytesMut;
+use bytes::{Bytes, BytesMut};
use tokio_util::codec::Decoder;
struct State {
@@ -80,7 +80,7 @@ impl FastCDC {
}
impl Decoder for FastCDC {
- type Item = BytesMut;
+ type Item = Bytes;
type Error = std::io::Error;
fn decode(&mut self, buf: &mut BytesMut) -> Result