publish init until RecvTimeout

liuxiaolong

2019-05-31 833ab389cdd29bc119602547b44d51d17d15b8fc

 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())