pub(crate) async fn replayer_mempool_task<DB: DatabaseRef + Send + Sync + Clone + 'static>( mempool: SharedState<Mempool>, market_state: SharedState<MarketState<DB>>, header: Header, ) -> Result<()>