From d5afefc540f877153f0e88f66e82b9a78cd062d3 Mon Sep 17 00:00:00 2001 From: Timon Ringwald Date: Thu, 17 Feb 2022 09:18:37 +0100 Subject: [PATCH] ofDelayedFunc further improved --- of.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/of.go b/of.go index f3a259e..d14e687 100644 --- a/of.go +++ b/of.go @@ -20,13 +20,13 @@ func OfDelayedFunc[T any](delayFunc func(value T) time.Duration, values ...T) <- out := make(chan T, len(values)) go func(out chan T, values []T) { + defer close(out) for i, value := range values { out <- value if i < len(values)-1 { time.Sleep(delayFunc(value)) } } - close(out) }(out, values) return out