Method schedulePing

psynetrpc.go:150–159

()

}

func (p *PsyNetRPC) schedulePing() {
	p.mu.Lock()
	defer p.mu.Unlock()

	if !p.connected || p.wsConn == nil {
		return
	}

	p.pingTimer = time.AfterFunc(pingInterval, p.sendPing)
}

func (p *PsyNetRPC) sendPing() {
	pingMessage, err := p.buildMessage(map[string]string{"PsyPing": ""}, nil)