liuxiaolong
2020-03-12 0c9642be9fb9ed7efa5330d67551bb78b47e0d10
use []byte replate interface
2个文件已修改
10 ■■■■ 已修改文件
mangos.go 6 ●●●● 补丁 | 查看 | 原始文档 | blame | 历史
pubsub.go 4 ●●●● 补丁 | 查看 | 原始文档 | blame | 历史
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)
    }
pubsub.go
@@ -8,9 +8,9 @@
    Recv() chan Message
    GetCliInfo() map[string]interface{}
    GetCliInfo() map[string][]byte
    SetResp(interface{})
    SetResp([]byte)
}
type Message struct {