pub(crate) async fn resubscribe( client: AsyncClient, topics: impl Iterator<Item = (&str, QoS)>, ) -> Result<()>