Function estimator_worker

async fn estimator_worker<T, N, DB>(
    client: Option<impl Provider<T, N> + Clone + 'static>,
    encoder: impl SwapEncoder + Send + Sync + Clone + 'static,
    compose_channel_rx: Broadcaster<MessageTxCompose<DB>>,
    compose_channel_tx: Broadcaster<MessageTxCompose<DB>>,
) -> WorkerResult
where
    T: Transport + Clone,
    N: Network,
    DB: DatabaseRef + DatabaseLoomExt + Send + Sync + Clone + 'static,