mirror of
https://github.com/pezkuwichain/pezkuwi-subxt.git
synced 2026-05-30 10:31:03 +00:00
* remove on_block_imported * remove on_block_imported Co-authored-by: Gav Wood <gavin@parity.io>
This commit is contained in:
Generated
+257
-257
File diff suppressed because it is too large
Load Diff
@@ -258,10 +258,10 @@ impl<D> Peer<D> {
|
|||||||
Default::default()
|
Default::default()
|
||||||
};
|
};
|
||||||
self.block_import.import_block(import_block, cache).expect("block_import failed");
|
self.block_import.import_block(import_block, cache).expect("block_import failed");
|
||||||
self.network.on_block_imported(header, true);
|
|
||||||
at = hash;
|
at = hash;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
self.network.update_chain();
|
||||||
self.network.service().announce_block(at.clone(), Vec::new());
|
self.network.service().announce_block(at.clone(), Vec::new());
|
||||||
at
|
at
|
||||||
}
|
}
|
||||||
@@ -770,10 +770,7 @@ pub trait TestNetFactory: Sized {
|
|||||||
|
|
||||||
// We poll `imported_blocks_stream`.
|
// We poll `imported_blocks_stream`.
|
||||||
while let Poll::Ready(Some(notification)) = peer.imported_blocks_stream.as_mut().poll_next(cx) {
|
while let Poll::Ready(Some(notification)) = peer.imported_blocks_stream.as_mut().poll_next(cx) {
|
||||||
peer.network.on_block_imported(
|
peer.network.service().announce_block(notification.hash, Vec::new());
|
||||||
notification.header,
|
|
||||||
true,
|
|
||||||
);
|
|
||||||
}
|
}
|
||||||
|
|
||||||
// We poll `finality_notification_stream`, but we only take the last event.
|
// We poll `finality_notification_stream`, but we only take the last event.
|
||||||
|
|||||||
Reference in New Issue
Block a user