diff --git a/Cargo.lock b/Cargo.lock
index 5dce532..ab7a179 100644
--- a/Cargo.lock
+++ b/Cargo.lock
@@ -6,7 +6,6 @@ version = 4
name = "arctictis"
version = "0.1.0"
dependencies = [
- "bytes",
"futures-util",
"itoa",
"thiserror",
diff --git a/Cargo.toml b/Cargo.toml
index 9690f6a..6c30e85 100644
--- a/Cargo.toml
+++ b/Cargo.toml
@@ -4,7 +4,7 @@ version = "0.1.0"
edition = "2024"
[dependencies]
-bytes = "1.11.0"
+# bytes = "1.11.0"
futures-util = "0.3.31"
itoa = "1.0.18"
thiserror = "2.0.17"
diff --git a/src/bytes_split.rs b/src/bytes_split.rs
index d4e40b4..f4c84b7 100644
--- a/src/bytes_split.rs
+++ b/src/bytes_split.rs
@@ -1,4 +1,4 @@
-use bytes::{Buf, Bytes};
+use tokio_util::bytes::{Buf, Bytes};
pub struct BytesSplit(Bytes, u8);
@@ -43,7 +43,7 @@ mod tests {
#![allow(clippy::unwrap_used)]
use super::*;
- use bytes::Bytes;
+ use tokio_util::bytes::Bytes;
#[test]
fn splits_on_commas() {
diff --git a/src/codec.rs b/src/codec.rs
index aae97bb..723dc0a 100644
--- a/src/codec.rs
+++ b/src/codec.rs
@@ -1,5 +1,7 @@
-use bytes::{BufMut, Bytes};
-use tokio_util::codec::{AnyDelimiterCodec, AnyDelimiterCodecError, Decoder, Encoder};
+use tokio_util::{
+ bytes::{BufMut, Bytes, BytesMut},
+ codec::{AnyDelimiterCodec, AnyDelimiterCodecError, Decoder, Encoder},
+};
use crate::{
bytes_split::BytesSplit,
@@ -28,11 +30,7 @@ where
{
type Error = std::io::Error;
- fn encode(
- &mut self,
- item: Cmd,
- dst: &mut tokio_util::bytes::BytesMut,
- ) -> Result<(), Self::Error> {
+ fn encode(&mut self, item: Cmd, dst: &mut BytesMut) -> Result<(), Self::Error> {
let params = item.params();
let est_len = Cmd::TEXT.len() + params.count() + params.total_size() + 1;
dst.reserve(est_len);
@@ -96,10 +94,7 @@ impl Decoder for Codec {
type Item = RawResponse;
type Error = DecoderError;
- fn decode(
- &mut self,
- src: &mut tokio_util::bytes::BytesMut,
- ) -> Result