Merge pull request #19 from libp2p/fix/16

fix: serialize publishing

p2p/host/eventbus/basic.go

@@ -173,7 +173,7 @@ func (b *basicBus) Subscribe(evtTypes interface{}, opts ...event.SubscriptionOpt
 			out.nodes[i] = n
 		}, func(n *node) {
 			if n.keepLast {
-				l := n.last.Load()
+				l := n.last
 				if l == nil {
 					return
 				}
@@ -223,15 +223,15 @@ func (b *basicBus) Emitter(evtType interface{}, opts ...event.EmitterOpt) (e eve
 
 type node struct {
 	// Note: make sure to NEVER lock basicBus.lk when this lock is held
-	lk sync.RWMutex
+	lk sync.Mutex
 
 	typ reflect.Type
 
 	// emitter ref count
 	nEmitters int32
 
 	keepLast bool
-	last     atomic.Value
+	last     interface{}
 
 	sinks []chan interface{}
 }
@@ -248,13 +248,13 @@ func (n *node) emit(event interface{}) {
 		panic(fmt.Sprintf("Emit called with wrong type. expected: %s, got: %s", n.typ, typ))
 	}
 
-	n.lk.RLock()
+	n.lk.Lock()
 	if n.keepLast {
-		n.last.Store(event)
+		n.last = event
 	}
 
 	for _, ch := range n.sinks {
 		ch <- event
 	}
-	n.lk.RUnlock()
+	n.lk.Unlock()
 }