Add a desync check in next_block

2014-11-25 19:17:53 -08:00
parent 9e8435141c
commit e8f12a4a1e
1 changed files with 1 additions and 0 deletions
--- a/src/lib.rs
+++ b/src/lib.rs
@@ -247,6 +247,7 @@ impl<'conn> Notifications<'conn> {
            return Ok(notification);
        }

+        check_desync!(self.conn.conn.borrow());
        match try!(self.conn.conn.borrow_mut().read_message_with_notification()) {
            NotificationResponse { pid, channel, payload } => {
                Ok(Notification {