pub async fn create_aggregator_grpc_server( config: BridgeConfig, ) -> Result<(SocketAddr, Sender<()>), BridgeError>