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 + 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