pub async fn maintain_transaction_pool<N, Client, P, St, Tasks>(
client: Client,
pool: P,
events: St,
task_spawner: Tasks,
config: MaintainPoolConfig,
)where
N: NodePrimitives,
Client: StateProviderFactory + BlockReaderIdExt + ChainSpecProvider + Clone + 'static,
P: TransactionPoolExt<Transaction: PoolTransaction<Consensus = N::SignedTx>> + 'static,
St: Stream<Item = CanonStateNotification<N>> + 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