Fix `wait_for_blocks` counting blocks that didn't go through consensus
* Initial commit
Forked at:
Parent branch: origin/master
* WIP
Forked at:
Parent branch: origin/master
@@ -384,11 +384,13 @@ where
Box::pin(async move {
while let Some(notification) = import_notification_stream.next().await {
+ if notification.is_new_best {
blocks.insert(notification.hash);
if blocks.len() == count {
break;
}
}
+ }
})
}
}
