pool_loader_worker

Function pool_loader_worker 

Source
pub async fn pool_loader_worker<P, PL, N, DB>(
    client: P,
    pool_loaders: Arc<PoolLoaders<PL, N>>,
    pools_config: PoolsLoadingConfig,
    market: Arc<RwLock<Market>>,
    market_state: Arc<RwLock<MarketState<DB>>>,
    tasks_rx: Sender<LoomTask>,
    market_events_tx: Sender<MarketEvents>,
) -> Result<()>
where N: Network<TransactionRequest = TransactionRequest>, P: Provider<N> + DebugProviderExt<N> + Send + Sync + Clone + 'static, PL: Provider<N> + Send + Sync + Clone + 'static, DB: Database + DatabaseRef + DatabaseCommit + Send + Sync + Clone + 'static,