private async Task SendResponseAsync(Stream stream, CancellationToken token)
        {
            using (var rpc = new JsonRpc(stream))
            {
                foreach (var type in _proxyTypes)
                {
                    rpc.AddLocalRpcTarget(type);
                }
                token.ThrowIfCancellationRequested();

                var service = GetOrCreateService();
                rpc.AddLocalRpcTarget(service, new JsonRpcTargetOptions
                {
                    MethodNameTransform = MethodNameTransform,

    public async Task StartAsync(CancellationToken serverToken)
    {
        while (!serverToken.IsCancellationRequested)
        {
            var stream = _rpcStreamFactory.CreateNew();
            await WaitForConnectionAsync(stream, serverToken);
            _ = SendResponseAsync(stream, serverToken);
        }
        serverToken.ThrowIfCancellationRequested();
    }

        private async Task SendResponseAsync(Stream stream, CancellationToken token)
        {
            using (var rpc = new JsonRpc(stream))
            {
                var targetOptions = new JsonRpcTargetOptions
                {
                    MethodNameTransform = MethodNameTransform,
                    EventNameTransform = EventNameTransform,
                    AllowNonPublicInvocation = false,
                    ClientRequiresNamedArguments = true,
                    DisposeOnDisconnect = true,