Client.cs

    public class Client
    {
        /// <summary>
        /// List of address to connect to. Will connect to the first one responding. Connected address can changed if disconnected.
        /// </summary>        
        public void Connect(IEnumerable<string> addresses)
        {
            
        }
      
        public Task<byte[]> SendRequestAsync(string service, string subject, byte[] message)
        {
            return null;
        }

        public Task SendOneWayAsync(string service, string subject, byte[] message)
        {
            return null;
        }
    }

IServerHandler.cs

    public interface IServerHandler
    {
        Task<Message> HandleRequestAsync(string service, string subject, byte[] body);

        void HandleOneWay(string service, string subject, byte[] body);
    }

ISubscriberHandler.cs

    public interface ISubscriberHandler
    {
        void Handle(string stream, byte[] body);
    }

Message.cs

    public struct Message
    {
        public Message(string subject, byte[] body)
        {
            Subject = subject;
            Body = body;
        }

        public string Subject { get; private set; }
        public byte[] Body { get; private set; } 
    }

Publisher.cs

    public class Publisher
    {
        public void Bind(string address, params object[] args)
        {
            
        }

        public void Publish(string stream, byte[] body)
        {
            
        }
    }

Server.cs

    public class Server
    {
        public Server(IServerHandler handler)
        {
            
        }

        /// <summary>
        /// Bind the server to an address. Can be called multiple times. Address for clients only
        /// </summary>
        /// <param name="address"></param>
        /// <param name="args"></param>
        public void Bind(string address, params object[] args)
        {
            
        }                        
    }

Subscriber.cs

    public class Subscriber
    {
        public Subscriber(ISubscriberHandler handler)
        {
            
        }

        /// <summary>
        /// List of address to connect to. Will connect to the first one responding. Connected address can changed if disconnected.
        /// </summary>        
        public void Connect(IEnumerable<string> addresses)
        {
            
        }

        public void Subscribe(string stream)
        {
            
        }
    }