Function MakeWshRpcWithChannels

pkg/wshutil/wshrpc.go:215–239

closes outputCh when inputCh is closed/done

(inputCh chan baseds.RpcInputChType, outputCh chan []byte, rpcCtx wshrpc.RpcContext, serverImpl ServerImpl, debugName string)

// closes outputCh when inputCh is closed/done
func MakeWshRpcWithChannels(inputCh chan baseds.RpcInputChType, outputCh chan []byte, rpcCtx wshrpc.RpcContext, serverImpl ServerImpl, debugName string) *WshRpc {
	if inputCh == nil {
		inputCh = make(chan baseds.RpcInputChType, DefaultInputChSize)
	}
	if outputCh == nil {
		outputCh = make(chan []byte, DefaultOutputChSize)
	}
	validateServerImpl(serverImpl)
	rtn := &WshRpc{
		Lock:               &sync.Mutex{},
		DebugName:          debugName,
		InputCh:            inputCh,
		OutputCh:           outputCh,
		CtxDoneCh:          make(chan string, CtxDoneChSize),
		RpcMap:             make(map[string]*rpcData),
		RpcContext:         &atomic.Pointer[wshrpc.RpcContext]{},
		EventListener:      MakeEventListener(),
		ServerImpl:         serverImpl,
		ResponseHandlerMap: make(map[string]*RpcResponseHandler),
	}
	rtn.RpcContext.Store(&rpcCtx)
	rtn.StreamBroker = streamclient.NewBroker(AdaptWshRpc(rtn))
	go rtn.runServer()
	return rtn
}

func MakeWshRpc(rpcCtx wshrpc.RpcContext, serverImpl ServerImpl, debugName string) *WshRpc {
	return MakeWshRpcWithChannels(nil, nil, rpcCtx, serverImpl, debugName)