We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 9d25328 commit bf021bbCopy full SHA for bf021bb
src/notification.rs
@@ -99,14 +99,15 @@ impl<'a> Iterator for BlockingIter<'a> {
99
100
fn next(&mut self) -> Option<Result<Notification>> {
101
let mut conn = self.conn.conn.borrow_mut();
102
- if conn.is_desynchronized() {
103
- return Some(Err(Error::IoError(desynchronized())));
104
- }
105
106
if let Some(notification) = conn.notifications.pop_front() {
107
return Some(Ok(notification));
108
}
109
+ if conn.is_desynchronized() {
+ return Some(Err(Error::IoError(desynchronized())));
+ }
110
+
111
match conn.read_message_with_notification() {
112
Ok(NotificationResponse { pid, channel, payload }) => {
113
Some(Ok(Notification {
0 commit comments