1 files changed, 16 insertions, 0 deletions
diff --git a/lib/input/replStream.h b/lib/input/replStream.h
new file mode 100644
index 0000000..983d9d3
--- /dev/null
+++ b/lib/input/replStream.h
@@ -0,0 +1,16 @@
+#ifndef MYGRATE_INPUT_REPLSTREAM_H
+#define MYGRATE_INPUT_REPLSTREAM_H
+
+#include "../eventSourceBase.h"
+#include "mysqlConn.h"
+
+namespace MyGrate::Input {
+	class ReplicationStream : public EventSourceBase, MySQLConn {
+	public:
+		using MySQLConn::MySQLConn;
+
+		void readEvents(EventHandlerBase &) override;
+	};
+}
+
+#endif