dnim/rust-postgres
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Move desync check back a bit

Browse Source
This commit is contained in:
Steven Fackler 2015-09-19 11:02:10 -07:00
parent 9d25328322
commit bf021bb475
1 changed files with 4 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
src/notification.rs
View File

@ -99,14 +99,15 @@ impl<'a> Iterator for BlockingIter<'a> {
fn next(&mut self) -> Option<Result<Notification>> {
let mut conn = self.conn.conn.borrow_mut();
if conn.is_desynchronized() {
return Some(Err(Error::IoError(desynchronized())));
}
if let Some(notification) = conn.notifications.pop_front() {
return Some(Ok(notification));
}
if conn.is_desynchronized() {
return Some(Err(Error::IoError(desynchronized())));
}
match conn.read_message_with_notification() {
Ok(NotificationResponse { pid, channel, payload }) => {
Some(Ok(Notification {