chore: fix spelling issues (#13978)

This commit is contained in:
planetBoy
2025-01-25 17:10:35 +01:00
committed by GitHub
parent 68a1de799d
commit 139fe14e5f
6 changed files with 7 additions and 7 deletions

View File

@ -25,7 +25,7 @@ use std::{
/// If the response arrived with insufficient number of bodies, the future /// If the response arrived with insufficient number of bodies, the future
/// will issue another request until all bodies are collected. /// will issue another request until all bodies are collected.
/// ///
/// It then proceeds to verify the downloaded bodies. In case of an validation error, /// It then proceeds to verify the downloaded bodies. In case of a validation error,
/// the future will start over. /// the future will start over.
/// ///
/// The future will filter out any empty headers (see [`alloy_consensus::Header::is_empty`]) from /// The future will filter out any empty headers (see [`alloy_consensus::Header::is_empty`]) from

View File

@ -175,7 +175,7 @@ impl<T: HeaderDownloader> Future for SpawnedDownloader<T> {
} }
} }
/// Commands delegated tot the spawned [`HeaderDownloader`] /// Commands delegated to the spawned [`HeaderDownloader`]
enum DownloaderUpdates<H> { enum DownloaderUpdates<H> {
UpdateSyncGap(SealedHeader<H>, SyncTarget), UpdateSyncGap(SealedHeader<H>, SyncTarget),
UpdateLocalHead(SealedHeader<H>), UpdateLocalHead(SealedHeader<H>),

View File

@ -30,7 +30,7 @@ pub struct BodyDownloaderMetrics {
pub buffered_responses: Gauge, pub buffered_responses: Gauge,
/// The number of blocks the internal buffer of the /// The number of blocks the internal buffer of the
/// downloader. /// downloader.
/// These are bodies that have been received, but not cannot be committed yet because they're /// These are bodies that have been received, but cannot be committed yet because they're
/// not contiguous /// not contiguous
pub buffered_blocks: Gauge, pub buffered_blocks: Gauge,
/// Total amount of memory used by the buffered blocks in bytes /// Total amount of memory used by the buffered blocks in bytes
@ -101,7 +101,7 @@ pub struct HeaderDownloaderMetrics {
pub buffered_responses: Gauge, pub buffered_responses: Gauge,
/// The number of blocks the internal buffer of the /// The number of blocks the internal buffer of the
/// downloader. /// downloader.
/// These are bodies that have been received, but not cannot be committed yet because they're /// These are bodies that have been received, but cannot be committed yet because they're
/// not contiguous /// not contiguous
pub buffered_blocks: Gauge, pub buffered_blocks: Gauge,
/// Total amount of memory used by the buffered blocks in bytes /// Total amount of memory used by the buffered blocks in bytes

View File

@ -1,4 +1,4 @@
//! A Protocol defines a P2P subprotocol in a `RLPx` connection //! A Protocol defines a P2P subprotocol in an `RLPx` connection
use crate::{Capability, EthMessageID, EthVersion}; use crate::{Capability, EthMessageID, EthVersion};

View File

@ -60,7 +60,7 @@ pub async fn connect_passthrough(
p2p_stream p2p_stream
} }
/// A Rplx subprotocol for testing /// An Rplx subprotocol for testing
pub mod proto { pub mod proto {
use super::*; use super::*;
use crate::{protocol::Protocol, Capability}; use crate::{protocol::Protocol, Capability};

View File

@ -48,7 +48,7 @@ impl PendingSessionHandle {
/// An established session with a remote peer. /// An established session with a remote peer.
/// ///
/// Within an active session that supports the `Ethereum Wire Protocol `, three high-level tasks can /// Within an active session that supports the `Ethereum Wire Protocol`, three high-level tasks can
/// be performed: chain synchronization, block propagation and transaction exchange. /// be performed: chain synchronization, block propagation and transaction exchange.
#[derive(Debug)] #[derive(Debug)]
pub struct ActiveSessionHandle<N: NetworkPrimitives> { pub struct ActiveSessionHandle<N: NetworkPrimitives> {