Function estimator_worker

async fn estimator_worker<DB: DatabaseRef + Send + Sync + Clone>(
    swap_encoder: impl SwapEncoder,
    compose_channel_rx: Broadcaster<MessageTxCompose<DB>>,
    compose_channel_tx: Broadcaster<MessageTxCompose<DB>>,
) -> WorkerResult