Method Ready

gate/server.go:299–310

Ready 连接成功后立刻调用Ready, 开启推送

(msg *meta.Message, stream meta.Gate_ReadyServer)

// Ready 连接成功后立刻调用Ready, 开启推送
func (g *Gate) Ready(msg *meta.Message, stream meta.Gate_ReadyServer) error {
	s, err := g.getSession(stream.Context())
	if err != nil {
		return errors.Trace(err)
	}

	for {
		m := <-s.push
		log.Debugf("recv push request m:%v", m)
		stream.Send(m)
	}
}

// Heartbeat nil.
func (g *Gate) Heartbeat(ctx context.Context, req *meta.GateHeartbeatRequest) (*meta.GateHeartbeatResponse, error) {