fix lock

pocke · Jan 17, 2015 · fbefc5e · fbefc5e
1 parent 51c1549
commit fbefc5e
Showing 1 changed file with 3 additions and 2 deletions.
diff --git a/goevent.go b/goevent.go
@@ -59,8 +59,6 @@ func New() Event {
 var _ Event = New()
 
 func (p *event) Trigger(args ...interface{}) error {
-	p.lmu.Lock()
-	defer p.lmu.Unlock()
 
 	arguments := make([]reflect.Value, 0, len(args))
 	argTypes := make([]reflect.Type, 0, len(args))
@@ -74,6 +72,9 @@ func (p *event) Trigger(args ...interface{}) error {
 		return err
 	}
 
+	p.lmu.RLock()
+	defer p.lmu.RUnlock()
+
 	wg := sync.WaitGroup{}
 	wg.Add(len(p.listeners))
 	for _, fn := range p.listeners {