jleony/nanoreth
1
0
Fork 0
mirror of https://github.com/hl-archive-node/nanoreth.git synced 2025-12-06 10:59:55 +00:00
Code Issues Packages Projects Releases Wiki Activity

feat: add subscribe_safe_block & subscribe_finalized_block to CanonicalInMemoryState (#10317)

Browse Source
This commit is contained in:
unitezen
2024-08-20 14:03:14 +07:00
committed by GitHub
parent cd05a96fee
commit 6898c30a65
1 changed files with 10 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

10
crates/chain-state/src/in_memory.rs
View File

@ -464,6 +464,16 @@ impl CanonicalInMemoryState {
self.inner.canon_state_notification_sender.subscribe() self.inner.canon_state_notification_sender.subscribe()
} }
/// Subscribe to new safe block events.
pub fn subscribe_safe_block(&self) -> watch::Receiver<Option<SealedHeader>> {
self.inner.chain_info_tracker.subscribe_to_safe_block()
}
/// Subscribe to new finalized block events.
pub fn subscribe_finalized_block(&self) -> watch::Receiver<Option<SealedHeader>> {
self.inner.chain_info_tracker.subscribe_to_finalized_block()
}
/// Attempts to send a new [`CanonStateNotification`] to all active Receiver handles. /// Attempts to send a new [`CanonStateNotification`] to all active Receiver handles.
pub fn notify_canon_state(&self, event: CanonStateNotification) { pub fn notify_canon_state(&self, event: CanonStateNotification) {
self.inner.canon_state_notification_sender.send(event).ok(); self.inner.canon_state_notification_sender.send(event).ok();