Merge pull request fluent#87 from tulequ/master

tagomoris · web-flow · commit 0e453b2c4b73 · 2020-09-29T22:38:23.000+09:00
stopRunning must be init for Close() work correctly
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()

Original file line number	Diff line number	Diff line change
`@@ -146,6 +146,7 @@ func newWithDialer(config Config, d dialer) (f *Fluent, err error) {`
`146`	`146`	`Config: config,`
`147`	`147`	`dialer: d,`
`148`	`148`	`pending: make(chan *msgToSend, config.BufferLimit),`
	`149`	`+ stopRunning: make(chan bool, 1),`
`149`	`150`	`}`
`150`	`151`	`f.wg.Add(1)`
`151`	`152`	`go f.run()`