(msg string)
| 664 | } |
| 665 | |
| 666 | func (handler *RpcResponseHandler) SendMessage(msg string) { |
| 667 | rpcMsg := &RpcMessage{ |
| 668 | Command: wshrpc.Command_Message, |
| 669 | Data: wshrpc.CommandMessageData{ |
| 670 | Message: msg, |
| 671 | }, |
| 672 | Route: handler.source, // send back to source |
| 673 | } |
| 674 | msgBytes, _ := json.Marshal(rpcMsg) // will never fail |
| 675 | select { |
| 676 | case handler.w.OutputCh <- msgBytes: |
| 677 | case <-handler.ctx.Done(): |
| 678 | } |
| 679 | } |
| 680 | |
| 681 | func (handler *RpcResponseHandler) SendResponse(data any, done bool) error { |
| 682 | defer func() { |