using System;

using System.IO;

using System.IO.Pipes;

using System.Threading.Tasks;

​

using StreamJsonRpc;

​

await new Duplex().RunAsync();

​

class Duplex

{

    public async Task RunAsync()

    {

        var server = new NamedPipeServerStream("JsonRpcDuplex", PipeDirection.InOut, maxNumberOfServerInstances: 1, PipeTransmissionMode.Byte, PipeOptions.Asynchronous);

        var client = new NamedPipeClientStream(".", "JsonRpcDuplex", PipeDirection.InOut, PipeOptions.Asynchronous);

        await Task.WhenAll(server.WaitForConnectionAsync(), client.ConnectAsync()).ConfigureAwait(false);

​

        var s1 = this.Server1(server, client);

        var s2 = this.Server2(client, server);

        await s1.Do2();

        await s2.Do1();

    }

​

    IHost2 Server1(Stream send, Stream recv)

    {

        var host = new Host2();

        var rpc = new JsonRpc(send, recv)

        {

            CancelLocallyInvokedMethodsWhenConnectionIsClosed = true

        };

        rpc.AddLocalRpcTarget(host, null);

​

        var service2 = rpc.Attach<IHost2>();

​

        rpc.StartListening();

        return service2;

    }

​

    IHost1 Server2(Stream send, Stream recv)

    {

        var host = new Host1();

        var rpc = new JsonRpc(send, recv)

        {

            CancelLocallyInvokedMethodsWhenConnectionIsClosed = true

        };

        rpc.AddLocalRpcTarget(host, null);

​

        var service1 = rpc.Attach<IHost1>();

​

        rpc.StartListening();

        return service1;

    }

​

    interface IHost1

    {

        Task Do1();

    }

​

    interface IHost2

    {

        Task Do2();

    }

​

    public class Host1 : IHost1

    {

        public Task Do1()

        {

            Console.WriteLine("Do1");

            return Task.CompletedTask;

        }

    }

​

    public class Host2 : IHost2

    {

        public Task Do2()

        {

            Console.WriteLine("Do2");

            return Task.CompletedTask;

        }

    }

}

​