diff --git a/session/events.go b/session/events.go index 0ad40d4b..3479a6ee 100644 --- a/session/events.go +++ b/session/events.go @@ -59,7 +59,10 @@ func (p *EventPool) Add(tag string, data interface{}) { e := NewEvent(tag, data) p.events = append([]Event{e}, p.events...) - go func() { p.NewEvents <- e }() + select { + case p.NewEvents <- e: + default: + } } func (p *EventPool) Log(level int, format string, args ...interface{}) {