Merge pull request #771 from imobachgs/wait-before-probing

Wait before probing

rust/agama-lib/src/manager.rs

@@ -28,6 +28,7 @@ impl<'a> ManagerClient<'a> {
     }
 
     pub async fn probe(&self) -> Result<(), ServiceError> {
+        self.wait().await?;
         Ok(self.manager_proxy.probe().await?)
     }
 
@@ -55,12 +56,12 @@ impl<'a> ManagerClient<'a> {
 
     /// Waits until the manager is idle.
     pub async fn wait(&self) -> Result<(), ServiceError> {
+        let mut stream = self.status_proxy.receive_current_changed().await;
         if !self.is_busy().await {
             return Ok(());
         }
 
-        let mut s = self.status_proxy.receive_current_changed().await;
-        while let Some(change) = s.next().await {
+        while let Some(change) = stream.next().await {
             if change.get().await? == 0 {
                 return Ok(());
             }

rust/package/agama-cli.changes

@@ -1,3 +1,9 @@
+-------------------------------------------------------------------
+Tue Sep 26 12:05:52 UTC 2023 - Imobach Gonzalez Sosa <[email protected]>
+
+- Wait until the manager is ready before probing
+  (gh#openSUSE/agama#771).
+
 -------------------------------------------------------------------
 Mon Sep 25 11:32:53 UTC 2023 - Imobach Gonzalez Sosa <[email protected]>