make chan stopRunning

Signed-off-by: Tuan Le <mr.lequoctuan@gmail.com>
fluent · Sep 22, 2020 · 3fe534f · 3fe534f
1 parent 89c0329
commit 3fe534f
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/fluent/fluent.go b/fluent/fluent.go
@@ -146,6 +146,7 @@ func newWithDialer(config Config, d dialer) (f *Fluent, err error) {
 			Config:  config,
 			dialer:  d,
 			pending: make(chan *msgToSend, config.BufferLimit),
+			stopRunning: make(chan bool, 1),
 		}
 		f.wg.Add(1)
 		go f.run()