using System;

using System.Threading;

using System.Threading.Tasks;

​

namespace Test1

{

    public class MainClass

    {

        struct ClientEndpoint

        {

            //Addr info

        }

​

        class Client  : IDisposable

        {

            private CancellationTokenSource _cts;

            private Task _readTask; 

            private bool _disposed;

​

            public Client()

            {

                _cts = new CancellationTokenSource();

            }

​

            public void Dispose()

            {

                if (!_disposed) 

                {

                    StopTasks ();

                    _disposed = true;

                }

            }

​

            public async Task ConnectAsync(ClientEndpoint ep)

            {

                //ConnectInternalAsync(ep);

                await Task.Delay(TimeSpan.FromMilliseconds(1));

​

                _readTask = Task.Run (async () => await ReadLoop (_cts.Token),

                    _cts.Token);

            }

​

            private async Task ReadLoop(CancellationToken ct)

            {

                await Task.Delay(TimeSpan.FromMilliseconds(1));

​

                while (!ct.IsCancellationRequested) 

                {

                    //var msg = ReadMsgAsync (ct);

                    //handleMessage(msg);

​

                    await Task.Delay(TimeSpan.FromMilliseconds(10), ct);

                }

            }

​

            private void StopTasks()

            {

                _cts.Cancel ();

                _readTask.Wait ();

            }

        }

​

        public static void Main (string[] args)

        {

            Console.WriteLine("Client");

        }

    }

}