commentary improved

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...) {
 	}