refactor: stream_bodies -> bodies_stream

paradigmxyz · Nov 12, 2022 · ac0b98c · ac0b98c
1 parent e9d7c77
commit ac0b98c
Show file tree

Hide file tree

Showing 3 changed files with 3 additions and 3 deletions.
diff --git a/crates/interfaces/src/p2p/bodies/downloader.rs b/crates/interfaces/src/p2p/bodies/downloader.rs
@@ -32,7 +32,7 @@ pub trait BodyDownloader: Sync + Send {
     ///
     /// It is *not* guaranteed that all the requested bodies are fetched: the downloader may close
     /// the stream before the entire range has been fetched for any reason
-    fn stream_bodies<'a, 'b, I>(&'a self, headers: I) -> BodiesStream<'a>
+    fn bodies_stream<'a, 'b, I>(&'a self, headers: I) -> BodiesStream<'a>
     where
         I: IntoIterator<Item = H256>,
         <I as IntoIterator>::IntoIter: Send + 'b,

diff --git a/crates/net/bodies-downloaders/src/concurrent.rs b/crates/net/bodies-downloaders/src/concurrent.rs
@@ -35,7 +35,7 @@ impl<C: BodiesClient> BodyDownloader for ConcurrentDownloader<C> {
         &self.client
     }
 
-    fn stream_bodies<'a, 'b, I>(&'a self, headers: I) -> BodiesStream<'a>
+    fn bodies_stream<'a, 'b, I>(&'a self, headers: I) -> BodiesStream<'a>
     where
         I: IntoIterator<Item = H256>,
         <I as IntoIterator>::IntoIter: Send + 'b,

diff --git a/crates/stages/src/stages/bodies.rs b/crates/stages/src/stages/bodies.rs
@@ -84,7 +84,7 @@ impl<DB: Database, D: BodyDownloader, C: Consensus> Stage<DB> for BodyStage<D, C
         let mut block_number = starting_block;
         while let Some((header_hash, body)) = self
             .downloader
-            .stream_bodies(
+            .bodies_stream(
                 header_hashes_cursor
                     .walk(starting_block)?
                     .filter_map(|item| item.ok().map(|(_, hash)| hash))