Struct WshRpc

pkg/wshutil/wshrpc.go:50–64

}

type WshRpc struct {
	Lock               *sync.Mutex
	InputCh            chan baseds.RpcInputChType
	OutputCh           chan []byte
	CtxDoneCh          chan string // for context cancellation, value is ResId
	RpcContext         *atomic.Pointer[wshrpc.RpcContext]
	RpcMap             map[string]*rpcData
	ServerImpl         ServerImpl
	EventListener      *EventListener
	ResponseHandlerMap map[string]*RpcResponseHandler // reqId => handler
	StreamBroker       *streamclient.Broker
	Debug              bool
	DebugName          string
	ServerDone         bool
}

type wshRpcContextKey struct{}
type wshRpcRespHandlerContextKey struct{}