add asynchronous STATUS handling on NotifyHandle

mattnenterprise · Feb 6, 2018 · 6e48c77 · 6e48c77
1 parent 757ac51
commit 6e48c77
Showing 1 changed file with 10 additions and 0 deletions.
diff --git a/src/client.rs b/src/client.rs
@@ -157,6 +157,16 @@ impl<'a, T: Read + Write + 'a> NotifyHandle<'a, T> {
         let response: Vec<u8> = self.client.run_command_and_read_response(&s)?;
         parse_notify_status(&response)
     }
+
+    pub fn wait(&mut self) -> Result<(String, Mailbox)> {
+        let mut response :Vec<u8> = Vec::new();
+        self.client.readline(&mut response).unwrap();
+        let mailboxes = parse_notify_status(&response);
+
+        // Exactly one mailbox per line
+        let mailbox = mailboxes.unwrap().into_iter().next().unwrap();
+        Ok(mailbox)
+    }
 }
 
 impl<'a, T: Read + Write + 'a> IdleHandle<'a, T> {