From 6d79f07f5a21dbb14547e71039002de4b611e8a1 Mon Sep 17 00:00:00 2001 From: Tordarus Date: Wed, 9 Feb 2022 12:19:19 +0100 Subject: [PATCH] commentary improved --- utils.go | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) 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...) { }