Method SendResponse

pkg/wshutil/wshrpc.go:681–709

(data any, done bool)

}

func (handler *RpcResponseHandler) SendResponse(data any, done bool) error {
	defer func() {
		panichandler.PanicHandler("SendResponse", recover())
	}()
	if handler.done.Load() {
		return fmt.Errorf("request already done, cannot send additional response")
	}
	if done {
		defer handler.close()
	}
	if handler.reqId == "" {
		return nil
	}
	msg := &RpcMessage{
		ResId: handler.reqId,
		Data:  data,
		Cont:  !done,
	}
	barr, err := json.Marshal(msg)
	if err != nil {
		return err
	}
	select {
	case handler.w.OutputCh <- barr:
		return nil
	case <-handler.ctx.Done():
		return fmt.Errorf("timeout sending response")
	}
}

func (handler *RpcResponseHandler) SendResponseError(err error) {
	defer func() {