Update throttler.go

channel close, notify should close
reugn · Dec 24, 2021 · 0f4e7af · 0f4e7af
1 parent e98f8bb
commit 0f4e7af
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/flow/throttler.go b/flow/throttler.go
@@ -112,6 +112,7 @@ func (th *Throttler) bufferize() {
 	}
 	close(th.done)
 	close(th.out)
+	close(th.notify)
 }
 
 // Via streams data through the given flow