another try to remove job observer leaks

webtor-io · Oct 8, 2024 · ae47dea · ae47dea
1 parent 2247001
commit ae47dea
Showing 1 changed file with 7 additions and 1 deletion.
diff --git a/services/job/job.go b/services/job/job.go
@@ -20,11 +20,17 @@ func (s *Observer) Close() {
 	s.mux.Lock()
 	defer s.mux.Unlock()
 	if !s.closed {
-		s.closed = true
 		close(s.C)
+		s.closed = true
 	}
 }
 
+func (s *Observer) isClosed() bool {
+	s.mux.Lock()
+	defer s.mux.Unlock()
+	return s.closed
+}
+
 func (s *Observer) Push(v LogItem) {
 	if !s.closed {
 		s.C <- v