loom_broadcast_broadcaster::anvil

Function anvil_broadcaster_worker

Source
async fn anvil_broadcaster_worker<P, T, DB>(
    client: P,
    bundle_rx: Broadcaster<MessageTxCompose<DB>>,
) -> WorkerResult
where T: Transport + Clone, P: Provider<T, Ethereum> + AnvilProviderExt<T, Ethereum> + Send + Sync + Clone + 'static, DB: Clone + Send + Sync,