From eb32a1e19dc385ce11e95a65bd2f6a14a6400e0b Mon Sep 17 00:00:00 2001 From: Umberto Baldi Date: Wed, 24 Feb 2021 16:08:23 +0100 Subject: [PATCH] (hopefully) fix send on closed channel panic --- bufferflow_timed.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/bufferflow_timed.go b/bufferflow_timed.go index 248292208..d0be90227 100644 --- a/bufferflow_timed.go +++ b/bufferflow_timed.go @@ -51,7 +51,6 @@ func (b *BufferflowTimed) Init() { } close(b.Input) - close(b.done) }() @@ -112,4 +111,5 @@ func (b *BufferflowTimed) IsBufferGloballySendingBackIncomingData() bool { func (b *BufferflowTimed) Close() { b.ticker.Stop() b.done <- true + close(b.done) }