Added skipping notimplemented events to support GTID enabled env

Author: Lior Sion

pymysqlreplication/tests/test_basic.py

@@ -59,6 +59,10 @@ def test_connection_stream_lost_event(self):
         self.stream.fetchone()
 
         event = self.stream.fetchone()
+
+        while (type(event) == NotImplementedEvent):
+            event = self.stream.fetchone()
+
         self.assertIsInstance(event, QueryEvent)
         self.assertEqual(event.query, query)