Check if channel was closed

kalleep · kalleep · commit 627a9cca6944 · 2025-12-09T17:14:56.000+01:00
diff --git a/internal/component/loki/source/drain.go b/internal/component/loki/source/drain.go
@@ -22,8 +22,11 @@ func Drain(recv loki.LogsReceiver, f func()) {
 			select {
 			case <-ctx.Done():
 				return
-			case <-recv.Chan():
+			case _, ok := <-recv.Chan():
 				// Consume and discard entries to prevent channel blocking
+				if !ok {
+					return
+				}
 			}
 		}
 	}()

Original file line number	Diff line number	Diff line change
`@@ -22,8 +22,11 @@ func Drain(recv loki.LogsReceiver, f func()) {`
`22`	`22`	`select {`
`23`	`23`	`case <-ctx.Done():`
`24`	`24`	`return`
`25`		`- case <-recv.Chan():`
	`25`	`+ case _, ok := <-recv.Chan():`
`26`	`26`	`// Consume and discard entries to prevent channel blocking`
	`27`	`+ if !ok {`
	`28`	`+ return`
	`29`	`+ }`
`27`	`30`	`}`
`28`	`31`	`}`
`29`	`32`	`}()`