Function SetupConnRpcClient

pkg/wshutil/wshutil.go:154–178

(conn net.Conn, serverImpl ServerImpl, debugStr string)

}

func SetupConnRpcClient(conn net.Conn, serverImpl ServerImpl, debugStr string) (*WshRpc, chan error, error) {
	inputCh := make(chan baseds.RpcInputChType, DefaultInputChSize)
	outputCh := make(chan []byte, DefaultOutputChSize)
	writeErrCh := make(chan error, 1)
	go func() {
		defer func() {
			panichandler.PanicHandler("SetupConnRpcClient:AdaptOutputChToStream", recover())
		}()
		writeErr := AdaptOutputChToStream(outputCh, conn)
		if writeErr != nil {
			writeErrCh <- writeErr
			close(writeErrCh)
		}
	}()
	go func() {
		defer func() {
			panichandler.PanicHandler("SetupConnRpcClient:AdaptStreamToMsgCh", recover())
		}()
		// when input is closed, close the connection
		defer conn.Close()
		AdaptStreamToMsgCh(conn, inputCh, nil)
	}()
	rtn := MakeWshRpcWithChannels(inputCh, outputCh, wshrpc.RpcContext{}, serverImpl, debugStr)
	return rtn, writeErrCh, nil
}

func tryTcpSocket(sockName string) (net.Conn, error) {
	addr, err := net.ResolveTCPAddr("tcp", sockName)