liuxiaolong
2020-03-12 0c9642be9fb9ed7efa5330d67551bb78b47e0d10
mangos.go
@@ -16,7 +16,7 @@
   svr *gopherdiscovery.DiscoveryServer
   cli *gopherdiscovery.DiscoveryClient
   cliInfo map[string]interface{}
   cliInfo map[string][]byte
   recvCh chan Message  //recv msg chan
}
@@ -158,14 +158,14 @@
   return ps.recvCh
}
func (ps *mangosPubSub) GetCliInfo() map[string]interface{} {
func (ps *mangosPubSub) GetCliInfo() map[string][]byte {
   if ps.svr != nil {
      return ps.cliInfo
   }
   return nil
}
func (ps *mangosPubSub) SetResp(r interface{}) {
func (ps *mangosPubSub) SetResp(r []byte) {
   if ps.cli != nil {
      ps.cli.SetResp(r)
   }