another try to remove job observer leaks

webtor-io · Oct 8, 2024 · 4061fd3 · 4061fd3
1 parent 3638669
commit 4061fd3
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/services/job/job.go b/services/job/job.go
@@ -358,11 +358,13 @@ func (s *Jobs) Log(ctx context.Context, id string) (c chan LogItem, err error) {
 				select {
 				case <-ctx.Done():
 					close(c)
+					close(o.C)
 					return
 				case i := <-o.C:
 					c <- i
 					if i.Level == Close {
 						close(c)
+						close(o.C)
 						return
 					}
 				}