Return if the stream is nonblocking

bjoernhaeuser · bjoernhaeuser · commit 27f93daa3f47 · 2013-06-27T10:28:23.000+02:00
If the stream is nonblocking we actually get this invalid packet and
should just stop.
diff --git a/pymysqlreplication/binlogstream.py b/pymysqlreplication/binlogstream.py
@@ -112,6 +112,9 @@ def fetchone(self):
                     continue
 
             if not pkt.is_ok_packet():
+                if not self.__blocking:
+                    return None
+
                 continue
 
             binlog_event = BinLogPacketWrapper(pkt, self.table_map,
