(ctx context.Context, service string, data interface{}, result interface{})
| 303 | } |
| 304 | |
| 305 | func (p *PsyNetRPC) sendRequestSync(ctx context.Context, service string, data interface{}, result interface{}) error { |
| 306 | respCh, err := p.sendRequestAsync(ctx, service, data) |
| 307 | if err != nil { |
| 308 | return fmt.Errorf("failed to send async request for service: %s, err: %w", service, err) |
| 309 | } |
| 310 | |
| 311 | return p.awaitResponse(ctx, respCh, result) |
| 312 | } |
| 313 | |
| 314 | // Events returns a channel that receives raw messages and connection events |
| 315 | func (p *PsyNetRPC) Events() <-chan *Event { |