overflow_backup_2018_0455/event_sender_go
4
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

sd

Browse Source
This commit is contained in:
geek 2017-05-16 13:06:39 +09:00
parent 5b9d23fdaa
commit 624e73c186
1 changed files with 5 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
event_sender.go
View File

@ -73,6 +73,10 @@ func Start(ch chan bool) (err error) {
return nil return nil
} }
func Stop() (err error) {
es := GetInstance()
es.stop()
}
func AddEventData(event interface{}) { func AddEventData(event interface{}) {
es := GetInstance() es := GetInstance()
es.lq.PushItem(event) es.lq.PushItem(event)
@ -92,7 +96,7 @@ func (es *EventSender) start() {
go es.checkQueue() go es.checkQueue()
} }
func (es *EventSender) Stop() { func (es *EventSender) stop() {
if es.sc != nil { if es.sc != nil {
es.lq.Close() es.lq.Close()
close(es.sc) close(es.sc)