File tree Expand file tree Collapse file tree 4 files changed +4
-4
lines changed
src/event_scanner/scanner Expand file tree Collapse file tree 4 files changed +4
-4
lines changed Original file line number Diff line number Diff line change @@ -42,7 +42,6 @@ impl EventScannerBuilder<LatestEvents> {
4242 self
4343 }
4444
45- #[ must_use]
4645 /// Sets the maximum number of block-range fetches to process concurrently when
4746 /// collecting the latest events.
4847 ///
@@ -54,6 +53,7 @@ impl EventScannerBuilder<LatestEvents> {
5453 /// Defaults to [`DEFAULT_MAX_CONCURRENT_FETCHES`][default].
5554 ///
5655 /// [default]: crate::event_scanner::scanner::DEFAULT_MAX_CONCURRENT_FETCHES
56+ #[ must_use]
5757 pub fn max_concurrent_fetches ( mut self , max_concurrent_fetches : usize ) -> Self {
5858 self . config . max_concurrent_fetches = max_concurrent_fetches;
5959 self
Original file line number Diff line number Diff line change @@ -14,7 +14,6 @@ impl EventScannerBuilder<Live> {
1414 self
1515 }
1616
17- #[ must_use]
1817 /// Sets the maximum number of block-range fetches to process concurrently for
1918 /// live streaming.
2019 ///
@@ -29,6 +28,7 @@ impl EventScannerBuilder<Live> {
2928 /// Defaults to [`DEFAULT_MAX_CONCURRENT_FETCHES`][default].
3029 ///
3130 /// [default]: crate::event_scanner::scanner::DEFAULT_MAX_CONCURRENT_FETCHES
31+ #[ must_use]
3232 pub fn max_concurrent_fetches ( mut self , max_concurrent_fetches : usize ) -> Self {
3333 self . config . max_concurrent_fetches = max_concurrent_fetches;
3434 self
Original file line number Diff line number Diff line change @@ -16,7 +16,6 @@ impl EventScannerBuilder<SyncFromBlock> {
1616 self
1717 }
1818
19- #[ must_use]
2019 /// Sets the maximum number of block-range fetches to process concurrently when
2120 /// synchronizing from a specific block.
2221 ///
@@ -28,6 +27,7 @@ impl EventScannerBuilder<SyncFromBlock> {
2827 /// Defaults to [`DEFAULT_MAX_CONCURRENT_FETCHES`][default].
2928 ///
3029 /// [default]: crate::event_scanner::scanner::DEFAULT_MAX_CONCURRENT_FETCHES
30+ #[ must_use]
3131 pub fn max_concurrent_fetches ( mut self , max_concurrent_fetches : usize ) -> Self {
3232 self . config . max_concurrent_fetches = max_concurrent_fetches;
3333 self
Original file line number Diff line number Diff line change @@ -22,7 +22,6 @@ impl EventScannerBuilder<SyncFromLatestEvents> {
2222 self
2323 }
2424
25- #[ must_use]
2625 /// Sets the maximum number of block-range fetches to process concurrently when
2726 /// fetching the latest events before switching to live streaming.
2827 ///
@@ -34,6 +33,7 @@ impl EventScannerBuilder<SyncFromLatestEvents> {
3433 /// Defaults to [`DEFAULT_MAX_CONCURRENT_FETCHES`][default].
3534 ///
3635 /// [default]: crate::event_scanner::scanner::DEFAULT_MAX_CONCURRENT_FETCHES
36+ #[ must_use]
3737 pub fn max_concurrent_fetches ( mut self , max_concurrent_fetches : usize ) -> Self {
3838 self . config . max_concurrent_fetches = max_concurrent_fetches;
3939 self
You can’t perform that action at this time.
0 commit comments