Method registerRpc

pkg/wshutil/wshrpc.go:469–487

(handler *RpcRequestHandler, command string, route string, reqId string)

}

func (w *WshRpc) registerRpc(handler *RpcRequestHandler, command string, route string, reqId string) chan *RpcMessage {
	w.Lock.Lock()
	defer w.Lock.Unlock()
	rpcCh := make(chan *RpcMessage, RespChSize)
	w.RpcMap[reqId] = &rpcData{
		Handler: handler,
		Command: command,
		Route:   route,
		ResCh:   rpcCh,
	}
	go func() {
		defer func() {
			panichandler.PanicHandler("registerRpc:timeout", recover())
		}()
		<-handler.ctx.Done()
		w.retrySendTimeout(reqId)
	}()
	return rpcCh
}

func (w *WshRpc) unregisterRpc(reqId string, err error) {
	w.Lock.Lock()