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,