From 5b46b8d941c2c6589e732d0396651e653998e59b Mon Sep 17 00:00:00 2001 From: evilsocket Date: Thu, 1 Feb 2018 12:53:44 +0100 Subject: [PATCH] fix: using buffered channel for events (fixes #37) --- session/events.go | 8 ++------ 1 file changed, 2 insertions(+), 6 deletions(-) diff --git a/session/events.go b/session/events.go index f3270ff7..6fdd6f7b 100644 --- a/session/events.go +++ b/session/events.go @@ -47,7 +47,7 @@ type EventPool struct { func NewEventPool(debug bool, silent bool) *EventPool { return &EventPool{ - NewEvents: make(chan Event), + NewEvents: make(chan Event, 0xff), debug: debug, silent: silent, events: make([]Event, 0), @@ -59,11 +59,7 @@ func (p *EventPool) Add(tag string, data interface{}) { defer p.Unlock() e := NewEvent(tag, data) p.events = append([]Event{e}, p.events...) - - select { - case p.NewEvents <- e: - default: - } + p.NewEvents <- e } func (p *EventPool) Log(level int, format string, args ...interface{}) {