Method loopRecvMessage

client/candy.go:340–353

loopRecvMessage 一直接收服务器返回消息, 直到退出.

()

// loopRecvMessage 一直接收服务器返回消息, 直到退出.
func (c *CandyClient) loopRecvMessage() {
	log.Debugf("start loopRecvMessage")

	for !c.stop {
		pm, err := c.stream.Recv()
		if err != nil {
			// 这里不退出会死循环
			c.handler.OnError(err.Error())
			break
		}

		c.handler.OnRecv(int32(pm.Event), int32(pm.Operate), pm.Msg.ID, pm.Msg.Group, pm.Msg.From, pm.Msg.To, pm.Msg.Body)
	}
}

// healthCheck 健康检查
func (c *CandyClient) healthCheck() {