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 bobPipe = new NamedPipeServerStream("JsonRpcDuplex", PipeDirection.InOut, maxNumberOfServerInstances: 1, PipeTransmissionMode.Byte, PipeOptions.Asynchronous);

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

        await Task.WhenAll(bobPipe.WaitForConnectionAsync(), sallyPipe.ConnectAsync()).ConfigureAwait(false);

​

        await Task.WhenAll(this.DoBob(bobPipe), this.DoSally(sallyPipe));

    }

​

    async Task DoBob(Stream pipe)

    {

        JsonRpc rpc = new(pipe)

        {

            CancelLocallyInvokedMethodsWhenConnectionIsClosed = true

        };

        rpc.AddLocalRpcTarget<IBob>(new Bob(), null);

        rpc.StartListening();

        var sally = rpc.Attach<ISally>();

        await sally.Drink();

    }

​

    async Task DoSally(Stream pipe)

    {

        JsonRpc rpc = new(pipe)

        {

            CancelLocallyInvokedMethodsWhenConnectionIsClosed = true

        };

        rpc.AddLocalRpcTarget<ISally>(new Sally(), null);

        rpc.StartListening();

        var bob = rpc.Attach<IBob>();

        await bob.Eat();

    }

​

    interface IBob

    {

        Task Eat();

    }

​

    interface ISally

    {

        Task Drink();

    }

​

    public class Bob : IBob

    {

        public Task Eat()

        {

            Console.WriteLine("Bob eats");

            return Task.CompletedTask;

        }

    }

​

    public class Sally : ISally

    {

        public Task Drink()

        {

            Console.WriteLine("Sally drinks");

            return Task.CompletedTask;

        }

    }

}

​