mirror of
https://github.com/paradigmxyz/reth.git
synced 2026-01-29 17:18:08 -05:00
chore: fix typo (#2296)
This commit is contained in:
@@ -221,7 +221,7 @@ where
|
||||
.map(|new_block| {
|
||||
let new_chain = new_block.expect("new block subscription never ends; qed");
|
||||
new_chain
|
||||
.commited()
|
||||
.committed()
|
||||
.map(|c| {
|
||||
c.blocks()
|
||||
.iter()
|
||||
|
||||
@@ -19,7 +19,7 @@ pub trait CanonStateSubscriptions: Send + Sync {
|
||||
|
||||
/// Chain action that is triggered when a new block is imported or old block is reverted.
|
||||
/// and will return all [`crate::PostState`] and [`reth_primitives::SealedBlockWithSenders`] of both
|
||||
/// reverted and commited blocks.
|
||||
/// reverted and committed blocks.
|
||||
#[derive(Clone, Debug)]
|
||||
#[allow(missing_docs)]
|
||||
pub enum CanonStateNotification {
|
||||
@@ -57,7 +57,7 @@ impl CanonStateNotification {
|
||||
}
|
||||
|
||||
/// Get new chain if any.
|
||||
pub fn commited(&self) -> Option<Arc<Chain>> {
|
||||
pub fn committed(&self) -> Option<Arc<Chain>> {
|
||||
match self {
|
||||
Self::Reorg { new, .. } => Some(new.clone()),
|
||||
Self::Revert { .. } => None,
|
||||
@@ -77,7 +77,7 @@ impl CanonStateNotification {
|
||||
.extend(old.receipts_with_attachment().into_iter().map(|receipt| (receipt, true)));
|
||||
}
|
||||
// get new receipts
|
||||
if let Some(new) = self.commited() {
|
||||
if let Some(new) = self.committed() {
|
||||
receipts
|
||||
.extend(new.receipts_with_attachment().into_iter().map(|receipt| (receipt, false)));
|
||||
}
|
||||
|
||||
Reference in New Issue
Block a user