(hopefully) fix send on closed channel panic (#621)

umbynos · umbynos · commit bbfbd440d570 · 2021-03-02T11:58:48.000+01:00
diff --git 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)
 }

Original file line number	Diff line number	Diff line change
`@@ -51,7 +51,6 @@ func (b *BufferflowTimed) Init() {`
`51`	`51`	`}`
`52`	`52`
`53`	`53`	`close(b.Input)`
`54`		`- close(b.done)`
`55`	`54`
`56`	`55`	`}()`
`57`	`56`
`@@ -112,4 +111,5 @@ func (b *BufferflowTimed) IsBufferGloballySendingBackIncomingData() bool {`
`112`	`111`	`func (b *BufferflowTimed) Close() {`
`113`	`112`	`b.ticker.Stop()`
`114`	`113`	`b.done <- true`
	`114`	`+ close(b.done)`
`115`	`115`	`}`