pubsub.go @@ -2,7 +2,7 @@ type PubSub interface { Publish([]byte) Publish(Message) Recv() chan Message }