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 state_hook_sender fn on StateRootTask (#13885)

Browse Source
This commit is contained in:
Dan Cline
2025-01-20 12:07:56 -05:00
committed by GitHub
parent 7483c1e292
commit 1e71002056
1 changed files with 8 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

11
crates/engine/tree/src/tree/root.rs
View File

@ -202,8 +202,8 @@ impl ProofSequencer {
} }
/// A wrapper for the sender that signals completion when dropped /// A wrapper for the sender that signals completion when dropped
#[derive(Deref)] #[derive(Deref, Debug)]
pub(crate) struct StateHookSender<BPF: BlindedProviderFactory>(Sender<StateRootMessage<BPF>>); pub struct StateHookSender<BPF: BlindedProviderFactory>(Sender<StateRootMessage<BPF>>);
impl<BPF: BlindedProviderFactory> StateHookSender<BPF> { impl<BPF: BlindedProviderFactory> StateHookSender<BPF> {
pub(crate) const fn new(inner: Sender<StateRootMessage<BPF>>) -> Self { pub(crate) const fn new(inner: Sender<StateRootMessage<BPF>>) -> Self {
@ -325,9 +325,14 @@ where
StateRootHandle::new(rx) StateRootHandle::new(rx)
} }
/// Returns a [`StateHookSender`] that can be used to send state updates to this task.
pub fn state_hook_sender(&self) -> StateHookSender<BPF> {
StateHookSender::new(self.tx.clone())
}
/// Returns a state hook to be used to send state updates to this task. /// Returns a state hook to be used to send state updates to this task.
pub fn state_hook(&self) -> impl OnStateHook { pub fn state_hook(&self) -> impl OnStateHook {
let state_hook = StateHookSender::new(self.tx.clone()); let state_hook = self.state_hook_sender();
move |state: &EvmState| { move |state: &EvmState| {
if let Err(error) = state_hook.send(StateRootMessage::StateUpdate(state.clone())) { if let Err(error) = state_hook.send(StateRootMessage::StateUpdate(state.clone())) {