From 861dcd00d8d56d746a3cd04203d4d027bee6ada9 Mon Sep 17 00:00:00 2001
From: bskjon <bskjon@outlook.com>
Date: Sat, 20 Jul 2024 01:23:26 +0200
Subject: [PATCH] v3 31

---
 .../coordinator/watcher/InputDirectoryWatcher.kt       | 10 ++++++----
 1 file changed, 6 insertions(+), 4 deletions(-)

diff --git a/apps/coordinator/src/main/kotlin/no/iktdev/mediaprocessing/coordinator/watcher/InputDirectoryWatcher.kt b/apps/coordinator/src/main/kotlin/no/iktdev/mediaprocessing/coordinator/watcher/InputDirectoryWatcher.kt
index 101c1a98..f79dc7af 100644
--- a/apps/coordinator/src/main/kotlin/no/iktdev/mediaprocessing/coordinator/watcher/InputDirectoryWatcher.kt
+++ b/apps/coordinator/src/main/kotlin/no/iktdev/mediaprocessing/coordinator/watcher/InputDirectoryWatcher.kt
@@ -74,10 +74,12 @@ class InputDirectoryWatcher(@Autowired var coordinator: Coordinator): FileWatche
                 e.printStackTrace()
             }
         }
-        log.warn { "Watcher stopped!!!" }
-        if (!isStopping) {
-            ioCoroutine.launch {
-                watchFiles()
+        watcherChannel.invokeOnClose {
+            log.warn { "Watcher stopped!!!" }
+            if (!isStopping) {
+                ioCoroutine.launch {
+                    watchFiles()
+                }
             }
         }
     }