publish init until RecvTimeout

liuxiaolong

2019-05-31 833ab389cdd29bc119602547b44d51d17d15b8fc

publish init until RecvTimeout

 server.go

@@ -149,11 +149,11 @@
    responses = NewStringSet()
    for {
        msg, err = d.sock.Recv()
        d.PublishMsg("Init")
        if err != nil {
            if err == mangos.ErrRecvTimeout {
                // Timeout means I can add the current responses to the SET
                d.services.Add(responses)
                d.PublishMsg("Init")
                return
            }
            //fmt.Println(" err: ",err.Error())