diff --git a/utils.go b/utils.go
index 8873523..59e4784 100644
--- a/utils.go
+++ b/utils.go
@@ -12,7 +12,8 @@ func determineBufferSize[T any](channels []<-chan T) int {
 	return bufSize / len(channels)
 }
 
-// Flush consumes all values and discards them immediately
+// Flush consumes all values and discards them immediately.
+// It blocks until all sources are closed
 func Flush[T any](sources ...<-chan T) {
 	for range Merge(sources...) {
 	}