2 files changed, 7 insertions, 0 deletions
diff --git a/lib/input/replStream.cpp b/lib/input/replStream.cpp
index c5bc61f..eb6c030 100644
--- a/lib/input/replStream.cpp
+++ b/lib/input/replStream.cpp
@@ -39,4 +39,10 @@ namespace MyGrate::Input {
 			}
 		}
 	}
+
+	void
+	ReplicationStream::stopEvents()
+	{
+		mariadb_cancel(this);
+	}
 }
diff --git a/lib/input/replStream.h b/lib/input/replStream.h
index dcfee19..40ec390 100644
--- a/lib/input/replStream.h
+++ b/lib/input/replStream.h
@@ -17,6 +17,7 @@ namespace MyGrate::Input {
 				unsigned short port, uint64_t serverid, std::string filename, uint64_t position);
 
 		void readEvents(EventHandlerBase &) override;
+		void stopEvents() override;
 
 	private:
 		uint64_t serverid;