Skip to content

Commit 7f941c6

Browse files
committed
chore: rename param
1 parent d9c14d6 commit 7f941c6

File tree

5 files changed

+13
-13
lines changed

5 files changed

+13
-13
lines changed

src/event_lib/modes/historic.rs

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -134,7 +134,7 @@ mod tests {
134134
#[test]
135135
fn test_historic_scanner_builder_pattern() {
136136
let config =
137-
HistoricScannerConfig::new().from_block(100u64).to_block(200u64).block_read_limit(50);
137+
HistoricScannerConfig::new().from_block(100u64).to_block(200u64).max_read_per_epoch(50);
138138

139139
assert!(matches!(config.from_block, BlockNumberOrTag::Number(100)));
140140
assert!(matches!(config.to_block, BlockNumberOrTag::Number(200)));
@@ -144,7 +144,7 @@ mod tests {
144144
#[test]
145145
fn test_historic_scanner_builder_pattern_chaining() {
146146
let config = HistoricScannerConfig::new()
147-
.block_read_limit(25)
147+
.max_read_per_epoch(25)
148148
.from_block(BlockNumberOrTag::Number(50))
149149
.to_block(BlockNumberOrTag::Number(150));
150150

src/event_lib/modes/latest.rs

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -182,7 +182,7 @@ impl<N: Network> LatestEventScanner<N> {
182182
self.inner.create_event_stream(filter)
183183
}
184184

185-
/// WARN: unimplemented - will call stream latest
185+
/// Calls stream latest
186186
///
187187
/// # Errors
188188
///
@@ -218,7 +218,7 @@ mod tests {
218218
.to_block(200)
219219
.block_confirmations(10)
220220
.then_live()
221-
.block_read_limit(50);
221+
.max_read_per_epoch(50);
222222

223223
assert_eq!(config.count, 5);
224224
assert!(matches!(config.from_block, BlockNumberOrTag::Number(100)));
@@ -231,7 +231,7 @@ mod tests {
231231
#[test]
232232
fn test_latest_scanner_builder_pattern_chaining() {
233233
let config = LatestScannerConfig::new()
234-
.block_read_limit(25)
234+
.max_read_per_epoch(25)
235235
.block_confirmations(5)
236236
.count(3)
237237
.from_block(BlockNumberOrTag::Number(50))

src/event_lib/modes/live.rs

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -119,23 +119,23 @@ mod tests {
119119

120120
#[test]
121121
fn test_live_scanner_builder_pattern() {
122-
let config = LiveScannerConfig::new().block_confirmations(10).block_read_limit(50);
122+
let config = LiveScannerConfig::new().block_confirmations(10).max_read_per_epoch(50);
123123

124124
assert_eq!(config.block_confirmations, 10);
125125
assert_eq!(config.base.block_range_scanner.max_read_per_epoch, 50);
126126
}
127127

128128
#[test]
129129
fn test_live_scanner_builder_pattern_chaining() {
130-
let config = LiveScannerConfig::new().block_read_limit(25).block_confirmations(5);
130+
let config = LiveScannerConfig::new().max_read_per_epoch(25).block_confirmations(5);
131131

132132
assert_eq!(config.base.block_range_scanner.max_read_per_epoch, 25);
133133
assert_eq!(config.block_confirmations, 5);
134134
}
135135

136136
#[test]
137137
fn test_live_scanner_builder_with_zero_confirmations() {
138-
let config = LiveScannerConfig::new().block_confirmations(0).block_read_limit(100);
138+
let config = LiveScannerConfig::new().block_confirmations(0).max_read_per_epoch(100);
139139

140140
assert_eq!(config.block_confirmations, 0);
141141
assert_eq!(config.base.block_range_scanner.max_read_per_epoch, 100);

src/event_lib/modes/mod.rs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -49,7 +49,7 @@ pub trait BaseConfigBuilder: Sized {
4949
fn base_mut(&mut self) -> &mut BaseConfig;
5050

5151
#[must_use]
52-
fn block_read_limit(mut self, max: usize) -> Self {
52+
fn max_read_per_epoch(mut self, max: usize) -> Self {
5353
self.base_mut().block_range_scanner.max_read_per_epoch = max;
5454
self
5555
}

src/event_lib/modes/sync.rs

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -134,7 +134,7 @@ mod tests {
134134
#[test]
135135
fn test_sync_scanner_builder_pattern() {
136136
let config =
137-
SyncScannerConfig::new().from_block(100).block_confirmations(10).block_read_limit(50);
137+
SyncScannerConfig::new().from_block(100).block_confirmations(10).max_read_per_epoch(50);
138138

139139
assert!(matches!(config.from_block, BlockNumberOrTag::Number(100)));
140140
assert_eq!(config.block_confirmations, 10);
@@ -144,7 +144,7 @@ mod tests {
144144
#[test]
145145
fn test_sync_scanner_builder_pattern_chaining() {
146146
let config = SyncScannerConfig::new()
147-
.block_read_limit(25)
147+
.max_read_per_epoch(25)
148148
.block_confirmations(5)
149149
.from_block(BlockNumberOrTag::Number(50));
150150

@@ -158,7 +158,7 @@ mod tests {
158158
let config = SyncScannerConfig::new()
159159
.from_block(BlockNumberOrTag::Earliest)
160160
.block_confirmations(20)
161-
.block_read_limit(100);
161+
.max_read_per_epoch(100);
162162

163163
assert!(matches!(config.from_block, BlockNumberOrTag::Earliest));
164164
assert_eq!(config.block_confirmations, 20);
@@ -168,7 +168,7 @@ mod tests {
168168
#[test]
169169
fn test_sync_scanner_builder_with_zero_confirmations() {
170170
let config =
171-
SyncScannerConfig::new().from_block(0).block_confirmations(0).block_read_limit(75);
171+
SyncScannerConfig::new().from_block(0).block_confirmations(0).max_read_per_epoch(75);
172172

173173
assert!(matches!(config.from_block, BlockNumberOrTag::Number(0)));
174174
assert_eq!(config.block_confirmations, 0);

0 commit comments

Comments
 (0)