//_socketServer.AddWebSocketService<JsonRpcBehavior>(Path, InitializeRpc);
JsonRpc.Attach<IServerProxy>(_rpcStream);

public async Task StartAsync(CancellationToken token)
{
    while (!token.IsCancellationRequested)
    {
        var stream = new NamedPipeServerStream(_pipeName, PipeDirection.InOut, _maxConcurrentRequests, PipeTransmissionMode.Byte, PipeOptions.Asynchronous);
        await stream.WaitForConnectionAsync(token);
        await SendResponseAsync(stream, token);
    }
    token.ThrowIfCancellationRequested();
}

    public abstract class JsonRpcServer<TStream> : IJsonRpcServer where TStream : Stream
    {
        private readonly IRpcStreamFactory<TStream> _rpcStreamFactory;
        private IEnumerable<Type> _proxyTypes;

        protected JsonRpcServer(IRpcStreamFactory<TStream> rpcStreamFactory)
        {
            _rpcStreamFactory = rpcStreamFactory;
            _proxyTypes = GetProxyTypes();
        }

        /// <summary>
        /// Wait for a client to connect.
        /// </summary>
        protected abstract Task WaitForConnectionAsync(TStream stream, CancellationToken token);

    /// <summary>
    /// A <c>JsonRpcServer</c> that runs a local database.
    /// </summary>
    public class LocalDbServer : JsonRpcServer<NamedPipeServerStream>
    {
        public LocalDbServer(IRpcStreamFactory<NamedPipeServerStream> rpcStreamFactory)
            : base(rpcStreamFactory)
        {
        }

        protected override async Task WaitForConnectionAsync(NamedPipeServerStream stream, CancellationToken token)
            => await stream.WaitForConnectionAsync(token);

        protected override IEnumerable<Type> GetProxyTypes() => new[]