fix: use futures iterator instead of tokio-stream

0xPolygonZero · Jun 7, 2024 · 4783f1a · 4783f1a
1 parent 4456338
commit 4783f1a
Show file tree

Hide file tree

Showing 4 changed files with 2 additions and 5 deletions.
diff --git a/Cargo.lock b/Cargo.lock
diff --git a/Cargo.toml b/Cargo.toml
@@ -10,7 +10,6 @@ tracing = "0.1"
 tracing-subscriber = { version = "0.3", features = ["env-filter"] }
 clap = { version = "4.4.6", features = ["derive", "env"] }
 tokio = { version = "1.33.0", features = ["full"] }
-tokio-stream = "0.1.15"
 serde = "1.0.183"
 serde_path_to_error = "0.1.14"
 serde_json = "1.0.107"

diff --git a/common/Cargo.toml b/common/Cargo.toml
@@ -20,6 +20,5 @@ serde = { workspace = true }
 serde_json = { workspace = true }
 futures = { workspace = true }
 tokio = { workspace = true }
-tokio-stream = { workspace = true }
 alloy = { workspace = true }
 async-stream = "0.3.5"
diff --git a/common/src/block_interval.rs b/common/src/block_interval.rs
@@ -117,9 +117,9 @@ impl BlockInterval {
                 let num = num
                     .as_number()
                     .ok_or(BlockIntervalError::InvalidBlockNumber(num.to_string()))?;
-                Ok(tokio_stream::iter(num..num + 1))
+                Ok(futures::stream::iter(num..num + 1))
             }
-            BlockInterval::Range(range) => Ok(tokio_stream::iter(range)),
+            BlockInterval::Range(range) => Ok(futures::stream::iter(range)),
             _ => Err(BlockIntervalError::IntoBoundedStreamError),
         }
     }