(err error)
| 709 | } |
| 710 | |
| 711 | func (handler *RpcResponseHandler) SendResponseError(err error) { |
| 712 | defer func() { |
| 713 | panichandler.PanicHandler("SendResponseError", recover()) |
| 714 | }() |
| 715 | if handler.done.Load() { |
| 716 | return |
| 717 | } |
| 718 | defer handler.close() |
| 719 | if handler.reqId == "" { |
| 720 | return |
| 721 | } |
| 722 | msg := &RpcMessage{ |
| 723 | ResId: handler.reqId, |
| 724 | Error: err.Error(), |
| 725 | } |
| 726 | barr, _ := json.Marshal(msg) // will never fail |
| 727 | select { |
| 728 | case handler.w.OutputCh <- barr: |
| 729 | case <-handler.ctx.Done(): |
| 730 | } |
| 731 | } |
| 732 | |
| 733 | func (handler *RpcResponseHandler) IsCanceled() bool { |
| 734 | return handler.canceled.Load() |
no test coverage detected