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