pub async fn run_service( addr: SocketAddr, rx: Receiver<()>, handlers: Arc<Mutex<Queue<HandlerCallback>>>, ) -> impl Future<Output = Result<(), Error>>