Merge pull request #134 from romuald/eof-packet-reset-status

julien-duponchelle · julien-duponchelle · commit 56ab0fd43e7b · 2015-12-04T20:36:34.000+01:00
Close connection on EOF packet
diff --git a/pymysqlreplication/binlogstream.py b/pymysqlreplication/binlogstream.py
@@ -249,6 +249,7 @@ def fetchone(self):
                     continue
 
             if pkt.is_eof_packet():
+                self.close()
                 return None
 
             if not pkt.is_ok_packet():
