diff --git a/watch.cpp b/watch.cpp
index 9b6b6f3..4e87431 100644
--- a/watch.cpp
+++ b/watch.cpp
@@ -22,6 +22,7 @@
 {
     if ((fd() >= 0) && (wd >= 0))
     {
+        sd_event_source_unref(source);
         inotify_rm_watch(fd(), wd);
     }
 }
@@ -51,7 +52,7 @@
     }
 
     auto rc =
-        sd_event_add_io(eventObj.get(), nullptr, fd(), events, callback, this);
+        sd_event_add_io(eventObj.get(), &source, fd(), events, callback, this);
     if (0 > rc)
     {
         // Failed to add to event loop
diff --git a/watch.hpp b/watch.hpp
index 96ec891..68e8728 100644
--- a/watch.hpp
+++ b/watch.hpp
@@ -92,6 +92,9 @@
 
     /** @brief The user level callback function wrapper */
     UserType userFunc;
+
+    /** @brief The event source object reference */
+    sd_event_source* source = nullptr;
 };
 
 } // namespace inotify