using System;

using System.Collections.Generic;

using System.Threading;

using System.Threading.Tasks;

using System.Threading.Tasks.Dataflow;

​

namespace TPLDataFlowTest

{

    public class Program

    {

        public static void Main(string[] args)

        {

            var service = new Service();

            Task.Delay(8000).Wait();

        }

​

    }

    class Server

    {

        public event Action<ServerClient> ClientConnected;

        public void Start()

        {

            SimulateClientConnections();

        }

        async Task SimulateClientConnections()

        {

            for (int i=0; i<5; i++)

            {

                await Task.Delay(1000);

                ClientConnected.Invoke(new ServerClient());

            }

        }

    }

    class ServerClient

    {

        public event Action<string> MessageReceived;    //Not sure whether to make it event based

        public Queue<string> ReceivedMessages;          //Or Simple Queue

        public ServerClient()

        {

            SimulateReceivedMessages(); 

        }

        async Task SimulateReceivedMessages()

        {

            for (int i=0; i<5; i++)

            {

                await Task.Delay(1000);

                MessageReceived.Invoke("Message #" + i.ToString());

            }

        }

    }

    class Service

    {

        Server server;

        public Service()

        {

            server = new Server();

            server.ClientConnected += OnClientConnected;

            server.Start();

        }

        void OnClientConnected(ServerClient serverClient)

        {

            var serverUser = new ServiceUser(serverClient);

            Console.WriteLine("New user connected");

        }

    }

    class ServiceUser

    {

        ServerClient serverClient;

        public ServiceUser(ServerClient serverClient)

        {

            this.serverClient = serverClient;

        }

    }

}

​