Skip to content

Commit 96de136

Browse files
authored
Fetch blocks and logs concurrently (#51)
1 parent 00ed8c5 commit 96de136

1 file changed

Lines changed: 4 additions & 3 deletions

File tree

be/src/sync.rs

Lines changed: 4 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -308,10 +308,11 @@ impl Downloader {
308308
tracing::Span::current()
309309
.record("from", from)
310310
.record("to", to);
311-
let (mut blocks, mut logs) = (
312-
self.jrpc_client.blocks(from, to).await?,
313-
self.jrpc_client.logs(from, to).await?,
311+
let (blocks_res, logs_res) = tokio::join!(
312+
self.jrpc_client.blocks(from, to),
313+
self.jrpc_client.logs(from, to),
314314
);
315+
let (mut blocks, mut logs) = (blocks_res?, logs_res?);
315316
add_timestamp(&mut blocks, &mut logs);
316317
validate_blocks(from, to, &blocks)?;
317318
validate_logs(&blocks, &logs)?;

0 commit comments

Comments
 (0)