DEFAULT_BUFFER_CAPACITY -> DEFAULT_STREAM_BUFFER_CAPACITY

Author: 0xNeshi

src/block_range_scanner.rs

@@ -93,7 +93,7 @@ pub const DEFAULT_MAX_BLOCK_RANGE: u64 = 1000;
 // copied form https://github.com/taikoxyz/taiko-mono/blob/f4b3a0e830e42e2fee54829326389709dd422098/packages/taiko-client/pkg/chain_iterator/block_batch_iterator.go#L19
 pub const DEFAULT_BLOCK_CONFIRMATIONS: u64 = 0;
 
-pub const DEFAULT_BUFFER_CAPACITY: usize = 50000;
+pub const DEFAULT_STREAM_BUFFER_CAPACITY: usize = 50000;
 
 // Maximum amount of reorged blocks on Ethereum (after this amount of block confirmations, a block
 // is considered final)
@@ -140,7 +140,7 @@ impl BlockRangeScanner {
         Self {
             max_block_range: DEFAULT_MAX_BLOCK_RANGE,
             past_blocks_storage_capacity: RingBufferCapacity::Limited(10),
-            buffer_capacity: DEFAULT_BUFFER_CAPACITY,
+            buffer_capacity: DEFAULT_STREAM_BUFFER_CAPACITY,
         }
     }
 
@@ -790,7 +790,7 @@ mod tests {
         let scanner = BlockRangeScanner::new();
 
         assert_eq!(scanner.max_block_range, DEFAULT_MAX_BLOCK_RANGE);
-        assert_eq!(scanner.buffer_capacity, DEFAULT_BUFFER_CAPACITY);
+        assert_eq!(scanner.buffer_capacity, DEFAULT_STREAM_BUFFER_CAPACITY);
     }
 
     #[test]

src/event_scanner/scanner/historic.rs

@@ -165,7 +165,7 @@ impl<N: Network> EventScanner<Historic, N> {
 #[cfg(test)]
 mod tests {
     use crate::{
-        DEFAULT_BUFFER_CAPACITY, block_range_scanner::DEFAULT_MAX_BLOCK_RANGE,
+        DEFAULT_STREAM_BUFFER_CAPACITY, block_range_scanner::DEFAULT_MAX_BLOCK_RANGE,
         event_scanner::scanner::DEFAULT_MAX_CONCURRENT_FETCHES,
     };
 
@@ -203,7 +203,7 @@ mod tests {
         assert_eq!(builder.config.to_block, BlockNumberOrTag::Latest.into());
         assert_eq!(builder.config.max_concurrent_fetches, DEFAULT_MAX_CONCURRENT_FETCHES);
         assert_eq!(builder.block_range_scanner.max_block_range, DEFAULT_MAX_BLOCK_RANGE);
-        assert_eq!(builder.block_range_scanner.buffer_capacity, DEFAULT_BUFFER_CAPACITY);
+        assert_eq!(builder.block_range_scanner.buffer_capacity, DEFAULT_STREAM_BUFFER_CAPACITY);
     }
 
     #[test]

src/event_scanner/scanner/latest.rs

@@ -165,7 +165,7 @@ impl<N: Network> EventScanner<LatestEvents, N> {
 #[cfg(test)]
 mod tests {
     use crate::{
-        DEFAULT_BUFFER_CAPACITY, block_range_scanner::DEFAULT_MAX_BLOCK_RANGE,
+        DEFAULT_STREAM_BUFFER_CAPACITY, block_range_scanner::DEFAULT_MAX_BLOCK_RANGE,
         event_scanner::scanner::DEFAULT_MAX_CONCURRENT_FETCHES,
     };
 
@@ -205,7 +205,7 @@ mod tests {
         assert_eq!(builder.config.count, 10);
         assert_eq!(builder.config.max_concurrent_fetches, DEFAULT_MAX_CONCURRENT_FETCHES);
         assert_eq!(builder.block_range_scanner.max_block_range, DEFAULT_MAX_BLOCK_RANGE);
-        assert_eq!(builder.block_range_scanner.buffer_capacity, DEFAULT_BUFFER_CAPACITY);
+        assert_eq!(builder.block_range_scanner.buffer_capacity, DEFAULT_STREAM_BUFFER_CAPACITY);
     }
 
     #[test]

src/event_scanner/scanner/live.rs

@@ -102,7 +102,7 @@ mod tests {
     use alloy_node_bindings::Anvil;
 
     use crate::{
-        DEFAULT_BUFFER_CAPACITY,
+        DEFAULT_STREAM_BUFFER_CAPACITY,
         block_range_scanner::{DEFAULT_BLOCK_CONFIRMATIONS, DEFAULT_MAX_BLOCK_RANGE},
         event_scanner::scanner::DEFAULT_MAX_CONCURRENT_FETCHES,
     };
@@ -130,7 +130,7 @@ mod tests {
         assert_eq!(builder.config.block_confirmations, DEFAULT_BLOCK_CONFIRMATIONS);
         assert_eq!(builder.config.max_concurrent_fetches, DEFAULT_MAX_CONCURRENT_FETCHES);
         assert_eq!(builder.block_range_scanner.max_block_range, DEFAULT_MAX_BLOCK_RANGE);
-        assert_eq!(builder.block_range_scanner.buffer_capacity, DEFAULT_BUFFER_CAPACITY);
+        assert_eq!(builder.block_range_scanner.buffer_capacity, DEFAULT_STREAM_BUFFER_CAPACITY);
     }
 
     #[test]

src/event_scanner/scanner/mod.rs

@@ -500,7 +500,7 @@ mod tests {
         rpc::client::RpcClient,
     };
 
-    use crate::DEFAULT_BUFFER_CAPACITY;
+    use crate::DEFAULT_STREAM_BUFFER_CAPACITY;
 
     use super::*;
 
@@ -510,15 +510,15 @@ mod tests {
 
         assert_eq!(builder.config.from_block, BlockNumberOrTag::Earliest.into());
         assert_eq!(builder.config.to_block, BlockNumberOrTag::Latest.into());
-        assert_eq!(builder.block_range_scanner.buffer_capacity, DEFAULT_BUFFER_CAPACITY);
+        assert_eq!(builder.block_range_scanner.buffer_capacity, DEFAULT_STREAM_BUFFER_CAPACITY);
     }
 
     #[test]
     fn test_live_scanner_config_defaults() {
         let builder = EventScannerBuilder::<Live>::default();
 
         assert_eq!(builder.config.block_confirmations, DEFAULT_BLOCK_CONFIRMATIONS);
-        assert_eq!(builder.block_range_scanner.buffer_capacity, DEFAULT_BUFFER_CAPACITY);
+        assert_eq!(builder.block_range_scanner.buffer_capacity, DEFAULT_STREAM_BUFFER_CAPACITY);
     }
 
     #[test]
@@ -529,7 +529,7 @@ mod tests {
 
         assert_eq!(builder.config.from_block, BlockNumberOrTag::Latest.into());
         assert_eq!(builder.config.to_block, BlockNumberOrTag::Earliest.into());
-        assert_eq!(builder.block_range_scanner.buffer_capacity, DEFAULT_BUFFER_CAPACITY);
+        assert_eq!(builder.block_range_scanner.buffer_capacity, DEFAULT_STREAM_BUFFER_CAPACITY);
     }
 
     #[test]
@@ -538,7 +538,7 @@ mod tests {
 
         assert_eq!(builder.config.from_block, BlockNumberOrTag::Earliest.into());
         assert_eq!(builder.config.block_confirmations, DEFAULT_BLOCK_CONFIRMATIONS);
-        assert_eq!(builder.block_range_scanner.buffer_capacity, DEFAULT_BUFFER_CAPACITY);
+        assert_eq!(builder.block_range_scanner.buffer_capacity, DEFAULT_STREAM_BUFFER_CAPACITY);
     }
 
     #[tokio::test]

src/event_scanner/scanner/sync/from_block.rs

@@ -112,7 +112,7 @@ mod tests {
     use alloy_node_bindings::Anvil;
 
     use crate::{
-        DEFAULT_BUFFER_CAPACITY,
+        DEFAULT_STREAM_BUFFER_CAPACITY,
         block_range_scanner::{DEFAULT_BLOCK_CONFIRMATIONS, DEFAULT_MAX_BLOCK_RANGE},
         event_scanner::scanner::DEFAULT_MAX_CONCURRENT_FETCHES,
     };
@@ -143,7 +143,7 @@ mod tests {
         assert_eq!(builder.config.block_confirmations, DEFAULT_BLOCK_CONFIRMATIONS);
         assert_eq!(builder.config.max_concurrent_fetches, DEFAULT_MAX_CONCURRENT_FETCHES);
         assert_eq!(builder.block_range_scanner.max_block_range, DEFAULT_MAX_BLOCK_RANGE);
-        assert_eq!(builder.block_range_scanner.buffer_capacity, DEFAULT_BUFFER_CAPACITY);
+        assert_eq!(builder.block_range_scanner.buffer_capacity, DEFAULT_STREAM_BUFFER_CAPACITY);
     }
 
     #[tokio::test]

src/event_scanner/scanner/sync/from_latest.rs

@@ -153,7 +153,7 @@ mod tests {
     use alloy_node_bindings::Anvil;
 
     use crate::{
-        DEFAULT_BUFFER_CAPACITY,
+        DEFAULT_STREAM_BUFFER_CAPACITY,
         block_range_scanner::{DEFAULT_BLOCK_CONFIRMATIONS, DEFAULT_MAX_BLOCK_RANGE},
         event_scanner::scanner::DEFAULT_MAX_CONCURRENT_FETCHES,
     };
@@ -184,7 +184,7 @@ mod tests {
         assert_eq!(builder.config.block_confirmations, DEFAULT_BLOCK_CONFIRMATIONS);
         assert_eq!(builder.block_range_scanner.max_block_range, DEFAULT_MAX_BLOCK_RANGE);
         assert_eq!(builder.config.max_concurrent_fetches, DEFAULT_MAX_CONCURRENT_FETCHES);
-        assert_eq!(builder.block_range_scanner.buffer_capacity, DEFAULT_BUFFER_CAPACITY);
+        assert_eq!(builder.block_range_scanner.buffer_capacity, DEFAULT_STREAM_BUFFER_CAPACITY);
     }
 
     #[test]

src/lib.rs

@@ -9,7 +9,7 @@ mod event_scanner;
 mod types;
 
 pub use block_range_scanner::{
-    DEFAULT_BUFFER_CAPACITY, RingBufferCapacity as PastBlocksStorageCapacity,
+    DEFAULT_STREAM_BUFFER_CAPACITY, RingBufferCapacity as PastBlocksStorageCapacity,
 };
 
 pub use error::ScannerError;