Method readMessages

psynetrpc.go:194–236

()

}

func (p *PsyNetRPC) readMessages() {
	defer func() {
		_ = p.Close()
	}()

	for {
		_, message, err := p.wsConn.ReadMessage()
		if err != nil {
			p.logger.Error("failed to read websocket message", slog.Any("err", err))
			break
		}

		if strings.HasPrefix(string(message), "PsyPong:") {
			select {
			case p.pongChan <- struct{}{}:
			default:
			}
			continue
		}

		p.logger.Debug("received websocket response", slog.String("message", string(message)))

		response, err := p.parseMessage(string(message))
		if err != nil {
			p.logger.Error("failed to parse psynet message", slog.Any("err", err), slog.String("message", string(message)))
			p.sendEvent(EventTypeMessage, string(message))
			continue
		}

		if response.ResponseID != "" {
			p.mu.Lock()
			ch, exists := p.pendingReqs[response.ResponseID]
			p.mu.Unlock()

			if exists {
				ch <- response
				continue
			}
		}

		p.sendEvent(EventTypeMessage, string(message))
	}
}

func (p *PsyNetRPC) sendRequestAsync(ctx context.Context, service string, data interface{}) (<-chan *PsyResponse, error) {
	if !p.IsConnected() {