Merge pull request julien-duponchelle#124 from giacomolozito/master

julien-duponchelle · julien-duponchelle · commit 4150b7e9b99b · 2015-07-05T10:56:34.000+02:00
Explicit close stream connection on exception
diff --git a/pymysqlreplication/binlogstream.py b/pymysqlreplication/binlogstream.py
@@ -244,6 +244,7 @@ def fetchone(self):
             except pymysql.OperationalError as error:
                 code, message = error.args
                 if code in MYSQL_EXPECTED_ERROR_CODES:
+                    self._stream_connection.close()
                     self.__connected_stream = False
                     continue
 
