liuxiaolong
2020-01-16 c43a8e3e552e00b653e40f45615bf46b2ddd40e2
pubsub.go
@@ -2,12 +2,15 @@
type PubSub interface {
   Publish([]byte)
   Publish(Message)
   Surveyor() []string
   Recv() chan Message
}
type Message struct {
   Id string
   Topic string
   Msg []byte
}