Skip to content

Commit d8eb30e

Browse files
author
Zoran Cvetkov
committed
fix futures
1 parent e657797 commit d8eb30e

File tree

1 file changed

+9
-6
lines changed

1 file changed

+9
-6
lines changed

graph/src/blockchain/block_stream.rs

Lines changed: 9 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -546,13 +546,16 @@ impl<C: Blockchain> TriggersAdapterWrapper<C> {
546546
return self.adapter.chain_head_ptr().await;
547547
}
548548

549-
let ptr = self
550-
.source_subgraph_stores
551-
.iter()
552-
.filter_map(|(_, store)| store.block_ptr())
553-
.min_by_key(|ptr| ptr.number);
549+
let ptrs = futures03::future::try_join_all(
550+
self.source_subgraph_stores
551+
.iter()
552+
.map(|(_, store)| store.block_ptr()),
553+
)
554+
.await?;
555+
556+
let min_ptr = ptrs.into_iter().flatten().min_by_key(|ptr| ptr.number);
554557

555-
Ok(ptr)
558+
Ok(min_ptr)
556559
}
557560
}
558561

0 commit comments

Comments
 (0)