aarnott / streamjsonrpc.sample Goto Github PK

using System;
using System.IO;
using System.IO.Pipes;
using System.Threading.Tasks;
using Nerdbank.Streams;
using StreamJsonRpc;

internal class Server
{
    public int Add(int a, int b)
    {
        Console.Error.WriteLine($"Received request: {a} + {b}");
        return a + b;
    }
}

class Program
{
    static async Task<int> Main(string[] args)
    {
        int clientId = 0;

        await Console.Error.WriteLineAsync($"Connection request #{clientId} received. Spinning off an async Task to cater to requests.");

        var nl = new NewLineDelimitedMessageHandler(Console.OpenStandardOutput(), Console.OpenStandardInput(), new JsonMessageFormatter());

        var jsonRpc = new JsonRpc(nl, new Server());

        await Console.Error.WriteLineAsync($"JSON-RPC listener attached to #{clientId}. Waiting for requests...");

        jsonRpc.StartListening();

        await jsonRpc.Completion;

        await Console.Error.WriteLineAsync($"Connection #{clientId} terminated.");

        return 0;
    }
}