fix: main watch loop cancel context

lucaschain · Dec 4, 2023 · 4c1267b · 4c1267b
1 parent 6e7a084
commit 4c1267b
Showing 1 changed file with 4 additions and 2 deletions.
diff --git a/infrastructure/file_watcher.go b/infrastructure/file_watcher.go
@@ -39,11 +39,13 @@ func FileWatcher(paths []string, callback core.ChangeCallback, ctx context.Conte
 	}
 	defer watcher.Close()
 
+	loopCtx, cancel := context.WithCancelCause(ctx)
+
 	go func() {
 		commandError := loop(watcher, callback)
 
 		if commandError != nil {
-			ctx.Done()
+			cancel(*commandError)
 		}
 	}()
 
@@ -54,7 +56,7 @@ func FileWatcher(paths []string, callback core.ChangeCallback, ctx context.Conte
 		}
 	}
 
-	<-ctx.Done()
+	<-loopCtx.Done()
 
 	err = ctx.Err()
 	return &err