raise exception

Windfarer · Windfarer · commit 5bc4fa6196ec · 2016-01-06T17:02:41.000+08:00
diff --git a/src/__init__.py b/src/__init__.py
@@ -253,6 +253,7 @@ def _binlog_loader(self):
                 yield rv
                 # print(rv)
         stream.close()
+        raise IOError('mysql connection closed')
 
     def _parse_table_structure(self, data):
         """
