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