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

chore: remove redundant Send bounds for BlockReader types (#13452)

Browse Source
This commit is contained in:
Dan Cline
2024-12-19 12:57:13 +02:00
committed by GitHub
parent d5a096f52f
commit 2eecf75c35
4 changed files with 10 additions and 10 deletions
Download Patch File Download Diff File Expand all files Collapse all files

10
crates/exex/exex/src/backfill/stream.rs
View File

@ -8,7 +8,7 @@ use futures::{
use reth_evm::execute::{BlockExecutionError, BlockExecutionOutput, BlockExecutorProvider}; use reth_evm::execute::{BlockExecutionError, BlockExecutionOutput, BlockExecutorProvider};
use reth_node_api::NodePrimitives; use reth_node_api::NodePrimitives;
use reth_primitives::{BlockWithSenders, EthPrimitives}; use reth_primitives::{BlockWithSenders, EthPrimitives};
use reth_provider::{BlockReader, Chain, HeaderProvider, StateProviderFactory}; use reth_provider::{BlockReader, Chain, StateProviderFactory};
use reth_prune_types::PruneModes; use reth_prune_types::PruneModes;
use reth_stages_api::ExecutionStageThresholds; use reth_stages_api::ExecutionStageThresholds;
use reth_tracing::tracing::debug; use reth_tracing::tracing::debug;
@ -114,8 +114,8 @@ where
impl<E, P> Stream for StreamBackfillJob<E, P, SingleBlockStreamItem<E::Primitives>> impl<E, P> Stream for StreamBackfillJob<E, P, SingleBlockStreamItem<E::Primitives>>
where where
E: BlockExecutorProvider<Primitives: NodePrimitives<Block = P::Block>> + Clone + Send + 'static, E: BlockExecutorProvider<Primitives: NodePrimitives<Block = P::Block>> + Clone + 'static,
P: HeaderProvider + BlockReader + StateProviderFactory + Clone + Send + Unpin + 'static, P: BlockReader + StateProviderFactory + Clone + Unpin + 'static,
{ {
type Item = BackfillJobResult<SingleBlockStreamItem<E::Primitives>>; type Item = BackfillJobResult<SingleBlockStreamItem<E::Primitives>>;
@ -147,8 +147,8 @@ where
impl<E, P> Stream for StreamBackfillJob<E, P, BatchBlockStreamItem<E::Primitives>> impl<E, P> Stream for StreamBackfillJob<E, P, BatchBlockStreamItem<E::Primitives>>
where where
E: BlockExecutorProvider<Primitives: NodePrimitives<Block = P::Block>> + Clone + Send + 'static, E: BlockExecutorProvider<Primitives: NodePrimitives<Block = P::Block>> + Clone + 'static,
P: HeaderProvider + BlockReader + StateProviderFactory + Clone + Send + Unpin + 'static, P: BlockReader + StateProviderFactory + Clone + Unpin + 'static,
{ {
type Item = BackfillJobResult<BatchBlockStreamItem<E::Primitives>>; type Item = BackfillJobResult<BatchBlockStreamItem<E::Primitives>>;

4
crates/rpc/rpc/src/eth/core.rs
View File

@ -158,7 +158,7 @@ where
impl<Provider, Pool, Network, EvmConfig> RpcNodeCore for EthApi<Provider, Pool, Network, EvmConfig> impl<Provider, Pool, Network, EvmConfig> RpcNodeCore for EthApi<Provider, Pool, Network, EvmConfig>
where where
Provider: BlockReader + Send + Sync + Clone + Unpin, Provider: BlockReader + Clone + Unpin,
Pool: Send + Sync + Clone + Unpin, Pool: Send + Sync + Clone + Unpin,
Network: Send + Sync + Clone, Network: Send + Sync + Clone,
EvmConfig: Send + Sync + Clone + Unpin, EvmConfig: Send + Sync + Clone + Unpin,
@ -193,7 +193,7 @@ where
impl<Provider, Pool, Network, EvmConfig> RpcNodeCoreExt impl<Provider, Pool, Network, EvmConfig> RpcNodeCoreExt
for EthApi<Provider, Pool, Network, EvmConfig> for EthApi<Provider, Pool, Network, EvmConfig>
where where
Provider: BlockReader + Send + Sync + Clone + Unpin, Provider: BlockReader + Clone + Unpin,
Pool: Send + Sync + Clone + Unpin, Pool: Send + Sync + Clone + Unpin,
Network: Send + Sync + Clone, Network: Send + Sync + Clone,
EvmConfig: Send + Sync + Clone + Unpin, EvmConfig: Send + Sync + Clone + Unpin,

2
crates/storage/storage-api/src/transactions.rs
View File

@ -86,7 +86,7 @@ pub type ProviderTx<P> = <P as TransactionsProvider>::Transaction;
/// Client trait for fetching additional transactions related data. /// Client trait for fetching additional transactions related data.
#[auto_impl::auto_impl(&, Arc)] #[auto_impl::auto_impl(&, Arc)]
pub trait TransactionsProviderExt: BlockReader + Send + Sync { pub trait TransactionsProviderExt: BlockReader {
/// Get transactions range by block range. /// Get transactions range by block range.
fn transaction_range_by_block_range( fn transaction_range_by_block_range(
&self, &self,

4
crates/transaction-pool/src/maintain.rs
View File

@ -83,7 +83,7 @@ where
BlockBody = reth_primitives::BlockBody, BlockBody = reth_primitives::BlockBody,
SignedTx = TransactionSigned, SignedTx = TransactionSigned,
>, >,
Client: StateProviderFactory + BlockReaderIdExt + ChainSpecProvider + Clone + Send + 'static, Client: StateProviderFactory + BlockReaderIdExt + ChainSpecProvider + Clone + 'static,
P: TransactionPoolExt<Transaction: PoolTransaction<Consensus = TransactionSigned>> + 'static, P: TransactionPoolExt<Transaction: PoolTransaction<Consensus = TransactionSigned>> + 'static,
St: Stream<Item = CanonStateNotification<N>> + Send + Unpin + 'static, St: Stream<Item = CanonStateNotification<N>> + Send + Unpin + 'static,
Tasks: TaskSpawner + 'static, Tasks: TaskSpawner + 'static,
@ -109,7 +109,7 @@ pub async fn maintain_transaction_pool<N, Client, P, St, Tasks>(
BlockBody = reth_primitives::BlockBody, BlockBody = reth_primitives::BlockBody,
SignedTx = TransactionSigned, SignedTx = TransactionSigned,
>, >,
Client: StateProviderFactory + BlockReaderIdExt + ChainSpecProvider + Clone + Send + 'static, Client: StateProviderFactory + BlockReaderIdExt + ChainSpecProvider + Clone + 'static,
P: TransactionPoolExt<Transaction: PoolTransaction<Consensus = TransactionSigned>> + 'static, P: TransactionPoolExt<Transaction: PoolTransaction<Consensus = TransactionSigned>> + 'static,
St: Stream<Item = CanonStateNotification<N>> + Send + Unpin + 'static, St: Stream<Item = CanonStateNotification<N>> + Send + Unpin + 'static,
Tasks: TaskSpawner + 'static, Tasks: TaskSpawner + 'static,