forgot to fix this in #621

umbynos · umbynos · commit 5db1975d2219 · 2021-08-04T18:02:09.000+02:00
diff --git a/bufferflow_timedbinary.go b/bufferflow_timedbinary.go
@@ -75,5 +75,5 @@ func (b *BufferflowTimedBinary) IsBufferGloballySendingBackIncomingData() bool {
 func (b *BufferflowTimedBinary) Close() {
 	b.ticker.Stop()
 	b.done <- true
-	close(b.input)
+	close(b.done)
 }
diff --git a/bufferflow_timedraw.go b/bufferflow_timedraw.go
@@ -71,5 +71,5 @@ func (b *BufferflowTimedRaw) OnIncomingData(data string) {
 func (b *BufferflowTimedRaw) Close() {
 	b.ticker.Stop()
 	b.done <- true
-	close(b.input)
+	close(b.done)
 }

Original file line number	Diff line number	Diff line change
`@@ -75,5 +75,5 @@ func (b *BufferflowTimedBinary) IsBufferGloballySendingBackIncomingData() bool {`
`75`	`75`	`func (b *BufferflowTimedBinary) Close() {`
`76`	`76`	`b.ticker.Stop()`
`77`	`77`	`b.done <- true`
`78`		`- close(b.input)`
	`78`	`+ close(b.done)`
`79`	`79`	`}`
Original file line number	Diff line number	Diff line change
`@@ -71,5 +71,5 @@ func (b *BufferflowTimedRaw) OnIncomingData(data string) {`
`71`	`71`	`func (b *BufferflowTimedRaw) Close() {`
`72`	`72`	`b.ticker.Stop()`
`73`	`73`	`b.done <- true`
`74`		`- close(b.input)`
	`74`	`+ close(b.done)`
`75`	`75`	`}`