Function estimator_task

async fn estimator_task<N, DB>(
    client: Option<impl Provider<N> + 'static>,
    swap_encoder: impl SwapEncoder,
    estimate_request: SwapComposeData<DB>,
    compose_channel_tx: Broadcaster<MessageSwapCompose<DB>>,
    health_monitor_channel_tx: Option<Broadcaster<MessageHealthEvent>>,
    influxdb_write_channel_tx: Option<Broadcaster<WriteQuery>>,
) -> Result<()>
where
    N: Network,
    DB: DatabaseRef<Error = KabuDBError> + Database<Error = KabuDBError> + DatabaseCommit + DatabaseKabuExt + Send + Sync + Clone + 'static,