Function estimator_worker 

async fn estimator_worker<N, DB>(
    client: Option<impl Provider<N> + Clone + 'static>,
    encoder: impl SwapEncoder + Send + Sync + Clone + 'static,
    compose_channel_rx: Receiver<MessageSwapCompose<DB>>,
    compose_channel_tx: Sender<MessageSwapCompose<DB>>,
    health_monitor_channel_tx: Option<Sender<MessageHealthEvent>>,
    influxdb_write_channel_tx: Option<Sender<WriteQuery>>,
)
where
    N: Network,
    DB: DatabaseRef<Error = KabuDBError> + Database<Error = KabuDBError> + DatabaseCommit + DatabaseKabuExt + Send + Sync + Clone + 'static,