Function reth_transaction_pool::maintain::maintain_transaction_pool
source · pub async fn maintain_transaction_pool<Client, P, St, Tasks>(
client: Client,
pool: P,
events: St,
task_spawner: Tasks,
config: MaintainPoolConfig,
)where
Client: StateProviderFactory + BlockReaderIdExt + ChainSpecProvider<ChainSpec = ChainSpec> + Clone + Send + 'static,
P: TransactionPoolExt + 'static,
St: Stream<Item = CanonStateNotification> + Send + Unpin + 'static,
Tasks: TaskSpawner + 'static,
Expand description
Maintains the state of the transaction pool by handling new blocks and reorgs.
This listens for any new blocks and reorgs and updates the transaction pool’s state accordingly