Merge pull request #42 from noplay/non_blocking_connections

Return if the stream is nonblocking

Author: julien-duponchelle

pymysqlreplication/binlogstream.py

@@ -111,6 +111,9 @@ def fetchone(self):
                     self.__connected_stream = False
                     continue
 
+            if pkt.is_eof_packet():
+                return None
+
             if not pkt.is_ok_packet():
                 continue