Explicit close stream connection on exception, to prevent sockets from sitting in CLOSE_WAIT status with PyPy

Author: giacomolozito

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