process_canonical_chain

kabu_defi_market::new_pool_actor

Function process_canonical_chain 

Source 
async fn process_canonical_chain<P, N>(
    chain: Arc<Chain<EthPrimitives>>,
    pools_loaders: &Arc<PoolLoaders<P, N>>,
    tasks_tx: &Sender<LoomTask>,
)
where
    N: Network,
    P: Provider<N> + Send + Sync + Clone + 'static,