Method Close

psynetrpc.go:65–92

()

}

func (p *PsyNetRPC) Close() error {
	p.mu.Lock()
	if p.wsConn != nil && p.connected {
		_ = p.wsConn.WriteMessage(websocket.CloseMessage, websocket.FormatCloseMessage(websocket.CloseNormalClosure, ""))
		err := p.wsConn.Close()

		// clean up pending events
		p.connected = false

		if p.pingTimer != nil {
			p.pingTimer.Stop()
			p.pingTimer = nil
		}

		for reqID, ch := range p.pendingReqs {
			close(ch)
			delete(p.pendingReqs, reqID)
		}

		p.mu.Unlock()
		p.sendEvent(EventTypeDisconnected, "")

		return err
	}

	p.mu.Unlock()
	return nil
}

func (p *PsyNetRPC) parseMessage(message string) (*PsyResponse, error) {
	delimiter := "\r\n\r\n"