public class TcpSession
    {
        #region Events
 
        /// <summary>
        /// Событие вызываемок при получении сообщения от клиента
        /// </summary>
        public event Action<object, ReceivedMessageEventArgs> MessageReceived;
 
        /// <summary>
        /// Событие вызываемое при какой-либо ожидаемой ошибке
        /// </summary>
        public event Action<object, ServerErrorArgs> SessionError;
 
        #endregion
 
        #region Private vars
 
        private Guid _sessionID = new Guid();
        private Task _sessionCommunicationTask = null;
        private CancellationToken _cancellationToken;
        private TcpClient _client = null;
        private NetworkStream _clientStream = null;
        private TcpSessionHandlerBase _handler = null;
        DateTime lastConnectionTimeChecked;       
        private bool _isStoped = false;
        private int _sessionLifetime = 60;
        private ConcurrentQueue<byte[]> _sendQueue = null;              //Потокобезопасная очередь отправки сообщений, нужна чтобы в теории из любого потока можно было добавить сообщение для отправки клиенту
 
        #endregion Private vars
 
        #region Props
 
        /// <summary>
        /// ID сессии
        /// </summary>
        public Guid ID => _sessionID;
 
        /// <summary>
        /// Остановленна ли текущая сессия
        /// </summary>
        public bool IsStoped => _isStoped;
 
        /// <summary>
        /// "Время жизни" сессии
        /// Подразумевается время между приемом-отправкой, во время которого не было получено или отправленно новых сообщений
        /// </summary>
        public int SessionLifetime 
        {
            get => _sessionLifetime;
            set{ if(value > 0)
                    _sessionLifetime = value;
                _sessionLifetime = 60;}
        }
 
        /// <summary>
        /// Метод получения конечной точки клиента
        /// </summary>
        /// <returns></returns>
        public EndPoint СlientEndPoint => _client.Client.RemoteEndPoint;
 
        #endregion Props
 
        #region ctor
 
        /// <summary>
        /// Конструктор сессии
        /// </summary>
        /// <param name="client"></param>
        public TcpSession(TcpClient client)
        {
            _sessionID = Guid.NewGuid();
            _client = client;
            //_handler = CreateHandler();
        }
 
        #endregion ctor
 
        #region Public
 
        /// <summary>
        /// Метод запуска сессии
        /// Предполагается что будет вызываться только из сервера
        /// </summary>
        /// <param name="cancellationToken"></param>
        public void Start(CancellationToken cancellationToken)
        {
            _cancellationToken = cancellationToken;
            if(_client != null)
            {
                _handler = CreateHandler();
                _sendQueue = new ConcurrentQueue<byte[]>();
                _sessionCommunicationTask = new Task(Process, cancellationToken);
                _sessionCommunicationTask.Start();
            }
        }
 
        /// <summary>
        /// Добавить сообщение в очередь отправки
        /// </summary>
        /// <param name="message"></param>
        public void AddMessageToSendQueue(byte[] message)
        {
            if(_sendQueue != null)
            {
                if(message != null && message.Length > 0)
                    _sendQueue.Enqueue(message);
            }
        }
 
        /// <summary>
        /// Метод остановки сессии
        /// </summary>
        public void Stop()
        {
            _isStoped = true;
            _client.Close();
        }
 
        #endregion Public
 
        #region Protected
 
        /// <summary>
        /// Виртуальный метод котоый нужен чтобы создать обработчик сессии, который будет что-то делать с пришедшими сообщениями
        /// </summary>
        /// <returns></returns>
        protected virtual TcpSessionHandlerBase CreateHandler()
        {
            return new TcpSessionHandlerBase(this);
        }
 
        #endregion
 
        #region Private
        /// <summary>
        /// Проверка не истекло ли время жизни сессии
        /// </summary>
        private bool isTimoutReached => (DateTime.Now - lastConnectionTimeChecked).TotalSeconds > _sessionLifetime;
 
        /// <summary>
        /// Основной метод работы сессии
        /// </summary>
        private void Process()
        {
            #region Бесполезное объяснение того как работает сессия
 
            #endregion
 
            try
            {
                lastConnectionTimeChecked = DateTime.Now;
                _clientStream = _client.GetStream();
                while(!(_cancellationToken.IsCancellationRequested || IsStoped))
                {
                    //Если истекло время жизни сессии
                    if(isTimoutReached)
                        break;
 
                    //Т.к. в теории не должно накапливаться много сообщений для отправки, отправляем по одному сообщению, в любом случае, очередь отправки должна будет заканчиваться быстрее чем приходят новые
                    if(_sendQueue.Count > 0)
                    {
                        byte[] msg;
                        if(_sendQueue.TryDequeue(out msg))
                            SendMessage(msg);
                    }
                    GetMessage(_clientStream);
                    //Thread.Sleep(100);
                }
            }
            catch(Exception ex)
            {
                SessionError?.Invoke(this, new ServerErrorArgs { ErrorMessage = ex.Message });
            }
            finally
            {
                _client.Close();
            }
            Stop();
        }
 
        /// <summary>
        /// Метод для получения сообщения из NetworkStream
        /// </summary>
        /// <param name="stream"></param>
        /// <returns></returns>
        private async Task<byte[]> GetMessage(NetworkStream stream)
        {
            using(MemoryStream ms = new MemoryStream())
            {
                byte[] data = new byte[64]; // буфер для получаемых данных
                int bytes = 0;
                do
                {
                    bytes = await _clientStream.ReadAsync(data);
                    await ms.WriteAsync(data, 0, bytes);
                } while(_clientStream.DataAvailable);
                if(ms.Length > 0)
                {
                    MessageReceived?.Invoke(this, new ReceivedMessageEventArgs() { Message = ms.ToArray() });
                    lastConnectionTimeChecked = DateTime.Now;
                    return ms.ToArray();
                }
            }
            return null;
        }
 
        /// <summary>
        /// Метод отправки сообщения клиенту
        /// </summary>
        /// <param name="message"></param>
        /// <returns></returns>
        private async Task SendMessage(byte[] message)
        {
            if(_clientStream.CanWrite)
            {
                await _clientStream.WriteAsync(message);
                lastConnectionTimeChecked = DateTime.Now;
            }
        }
        #endregion Private
    }

cHVibGljIGNsYXNzIFRjcFNlc3Npb24KICAgIHsKICAgICAgICAjcmVnaW9uIEV2ZW50cwoKICAgICAgICAvLy8gPHN1bW1hcnk+CiAgICAgICAgLy8vINCh0L7QsdGL0YLQuNC1INCy0YvQt9GL0LLQsNC10LzQvtC6INC/0YDQuCDQv9C+0LvRg9GH0LXQvdC40Lgg0YHQvtC+0LHRidC10L3QuNGPINC+0YIg0LrQu9C40LXQvdGC0LAKICAgICAgICAvLy8gPC9zdW1tYXJ5PgogICAgICAgIHB1YmxpYyBldmVudCBBY3Rpb248b2JqZWN0LCBSZWNlaXZlZE1lc3NhZ2VFdmVudEFyZ3M+IE1lc3NhZ2VSZWNlaXZlZDsKCiAgICAgICAgLy8vIDxzdW1tYXJ5PgogICAgICAgIC8vLyDQodC+0LHRi9GC0LjQtSDQstGL0LfRi9Cy0LDQtdC80L7QtSDQv9GA0Lgg0LrQsNC60L7QuS3Qu9C40LHQviDQvtC20LjQtNCw0LXQvNC+0Lkg0L7RiNC40LHQutC1CiAgICAgICAgLy8vIDwvc3VtbWFyeT4KICAgICAgICBwdWJsaWMgZXZlbnQgQWN0aW9uPG9iamVjdCwgU2VydmVyRXJyb3JBcmdzPiBTZXNzaW9uRXJyb3I7CgogICAgICAgICNlbmRyZWdpb24KCiAgICAgICAgI3JlZ2lvbiBQcml2YXRlIHZhcnMKCiAgICAgICAgcHJpdmF0ZSBHdWlkIF9zZXNzaW9uSUQgPSBuZXcgR3VpZCgpOwogICAgICAgIHByaXZhdGUgVGFzayBfc2Vzc2lvbkNvbW11bmljYXRpb25UYXNrID0gbnVsbDsKICAgICAgICBwcml2YXRlIENhbmNlbGxhdGlvblRva2VuIF9jYW5jZWxsYXRpb25Ub2tlbjsKICAgICAgICBwcml2YXRlIFRjcENsaWVudCBfY2xpZW50ID0gbnVsbDsKICAgICAgICBwcml2YXRlIE5ldHdvcmtTdHJlYW0gX2NsaWVudFN0cmVhbSA9IG51bGw7CiAgICAgICAgcHJpdmF0ZSBUY3BTZXNzaW9uSGFuZGxlckJhc2UgX2hhbmRsZXIgPSBudWxsOwogICAgICAgIERhdGVUaW1lIGxhc3RDb25uZWN0aW9uVGltZUNoZWNrZWQ7ICAgICAgIAogICAgICAgIHByaXZhdGUgYm9vbCBfaXNTdG9wZWQgPSBmYWxzZTsKICAgICAgICBwcml2YXRlIGludCBfc2Vzc2lvbkxpZmV0aW1lID0gNjA7CiAgICAgICAgcHJpdmF0ZSBDb25jdXJyZW50UXVldWU8Ynl0ZVtdPiBfc2VuZFF1ZXVlID0gbnVsbDsgICAgICAgICAgICAgIC8v0J/QvtGC0L7QutC+0LHQtdC30L7Qv9Cw0YHQvdCw0Y8g0L7Rh9C10YDQtdC00Ywg0L7RgtC/0YDQsNCy0LrQuCDRgdC+0L7QsdGJ0LXQvdC40LksINC90YPQttC90LAg0YfRgtC+0LHRiyDQsiDRgtC10L7RgNC40Lgg0LjQtyDQu9GO0LHQvtCz0L4g0L/QvtGC0L7QutCwINC80L7QttC90L4g0LHRi9C70L4g0LTQvtCx0LDQstC40YLRjCDRgdC+0L7QsdGJ0LXQvdC40LUg0LTQu9GPINC+0YLQv9GA0LDQstC60Lgg0LrQu9C40LXQvdGC0YMKCiAgICAgICAgI2VuZHJlZ2lvbiBQcml2YXRlIHZhcnMKCiAgICAgICAgI3JlZ2lvbiBQcm9wcwoKICAgICAgICAvLy8gPHN1bW1hcnk+CiAgICAgICAgLy8vIElEINGB0LXRgdGB0LjQuAogICAgICAgIC8vLyA8L3N1bW1hcnk+CiAgICAgICAgcHVibGljIEd1aWQgSUQgPT4gX3Nlc3Npb25JRDsKICAgICAgICAKICAgICAgICAvLy8gPHN1bW1hcnk+CiAgICAgICAgLy8vINCe0YHRgtCw0L3QvtCy0LvQtdC90L3QsCDQu9C4INGC0LXQutGD0YnQsNGPINGB0LXRgdGB0LjRjwogICAgICAgIC8vLyA8L3N1bW1hcnk+CiAgICAgICAgcHVibGljIGJvb2wgSXNTdG9wZWQgPT4gX2lzU3RvcGVkOwoKICAgICAgICAvLy8gPHN1bW1hcnk+CiAgICAgICAgLy8vICLQktGA0LXQvNGPINC20LjQt9C90LgiINGB0LXRgdGB0LjQuAogICAgICAgIC8vLyDQn9C+0LTRgNCw0LfRg9C80LXQstCw0LXRgtGB0Y8g0LLRgNC10LzRjyDQvNC10LbQtNGDINC/0YDQuNC10LzQvtC8LdC+0YLQv9GA0LDQstC60L7QuSwg0LLQviDQstGA0LXQvNGPINC60L7RgtC+0YDQvtCz0L4g0L3QtSDQsdGL0LvQviDQv9C+0LvRg9GH0LXQvdC+INC40LvQuCDQvtGC0L/RgNCw0LLQu9C10L3QvdC+INC90L7QstGL0YUg0YHQvtC+0LHRidC10L3QuNC5CiAgICAgICAgLy8vIDwvc3VtbWFyeT4KICAgICAgICBwdWJsaWMgaW50IFNlc3Npb25MaWZldGltZSAKICAgICAgICB7CiAgICAgICAgICAgIGdldCA9PiBfc2Vzc2lvbkxpZmV0aW1lOwogICAgICAgICAgICBzZXR7IGlmKHZhbHVlID4gMCkKICAgICAgICAgICAgICAgICAgICBfc2Vzc2lvbkxpZmV0aW1lID0gdmFsdWU7CiAgICAgICAgICAgICAgICBfc2Vzc2lvbkxpZmV0aW1lID0gNjA7fQogICAgICAgIH0KCiAgICAgICAgLy8vIDxzdW1tYXJ5PgogICAgICAgIC8vLyDQnNC10YLQvtC0INC/0L7Qu9GD0YfQtdC90LjRjyDQutC+0L3QtdGH0L3QvtC5INGC0L7Rh9C60Lgg0LrQu9C40LXQvdGC0LAKICAgICAgICAvLy8gPC9zdW1tYXJ5PgogICAgICAgIC8vLyA8cmV0dXJucz48L3JldHVybnM+CiAgICAgICAgcHVibGljIEVuZFBvaW50INChbGllbnRFbmRQb2ludCA9PiBfY2xpZW50LkNsaWVudC5SZW1vdGVFbmRQb2ludDsKCiAgICAgICAgI2VuZHJlZ2lvbiBQcm9wcwoKICAgICAgICAjcmVnaW9uIGN0b3IKCiAgICAgICAgLy8vIDxzdW1tYXJ5PgogICAgICAgIC8vLyDQmtC+0L3RgdGC0YDRg9C60YLQvtGAINGB0LXRgdGB0LjQuAogICAgICAgIC8vLyA8L3N1bW1hcnk+CiAgICAgICAgLy8vIDxwYXJhbSBuYW1lPSJjbGllbnQiPjwvcGFyYW0+CiAgICAgICAgcHVibGljIFRjcFNlc3Npb24oVGNwQ2xpZW50IGNsaWVudCkKICAgICAgICB7CiAgICAgICAgICAgIF9zZXNzaW9uSUQgPSBHdWlkLk5ld0d1aWQoKTsKICAgICAgICAgICAgX2NsaWVudCA9IGNsaWVudDsKICAgICAgICAgICAgLy9faGFuZGxlciA9IENyZWF0ZUhhbmRsZXIoKTsKICAgICAgICB9CgogICAgICAgICNlbmRyZWdpb24gY3RvcgoKICAgICAgICAjcmVnaW9uIFB1YmxpYwoKICAgICAgICAvLy8gPHN1bW1hcnk+CiAgICAgICAgLy8vINCc0LXRgtC+0LQg0LfQsNC/0YPRgdC60LAg0YHQtdGB0YHQuNC4CiAgICAgICAgLy8vINCf0YDQtdC00L/QvtC70LDQs9Cw0LXRgtGB0Y8g0YfRgtC+INCx0YPQtNC10YIg0LLRi9C30YvQstCw0YLRjNGB0Y8g0YLQvtC70YzQutC+INC40Lcg0YHQtdGA0LLQtdGA0LAKICAgICAgICAvLy8gPC9zdW1tYXJ5PgogICAgICAgIC8vLyA8cGFyYW0gbmFtZT0iY2FuY2VsbGF0aW9uVG9rZW4iPjwvcGFyYW0+CiAgICAgICAgcHVibGljIHZvaWQgU3RhcnQoQ2FuY2VsbGF0aW9uVG9rZW4gY2FuY2VsbGF0aW9uVG9rZW4pCiAgICAgICAgewogICAgICAgICAgICBfY2FuY2VsbGF0aW9uVG9rZW4gPSBjYW5jZWxsYXRpb25Ub2tlbjsKICAgICAgICAgICAgaWYoX2NsaWVudCAhPSBudWxsKQogICAgICAgICAgICB7CiAgICAgICAgICAgICAgICBfaGFuZGxlciA9IENyZWF0ZUhhbmRsZXIoKTsKICAgICAgICAgICAgICAgIF9zZW5kUXVldWUgPSBuZXcgQ29uY3VycmVudFF1ZXVlPGJ5dGVbXT4oKTsKICAgICAgICAgICAgICAgIF9zZXNzaW9uQ29tbXVuaWNhdGlvblRhc2sgPSBuZXcgVGFzayhQcm9jZXNzLCBjYW5jZWxsYXRpb25Ub2tlbik7CiAgICAgICAgICAgICAgICBfc2Vzc2lvbkNvbW11bmljYXRpb25UYXNrLlN0YXJ0KCk7CiAgICAgICAgICAgIH0KICAgICAgICB9CgogICAgICAgIC8vLyA8c3VtbWFyeT4KICAgICAgICAvLy8g0JTQvtCx0LDQstC40YLRjCDRgdC+0L7QsdGJ0LXQvdC40LUg0LIg0L7Rh9C10YDQtdC00Ywg0L7RgtC/0YDQsNCy0LrQuAogICAgICAgIC8vLyA8L3N1bW1hcnk+CiAgICAgICAgLy8vIDxwYXJhbSBuYW1lPSJtZXNzYWdlIj48L3BhcmFtPgogICAgICAgIHB1YmxpYyB2b2lkIEFkZE1lc3NhZ2VUb1NlbmRRdWV1ZShieXRlW10gbWVzc2FnZSkKICAgICAgICB7CiAgICAgICAgICAgIGlmKF9zZW5kUXVldWUgIT0gbnVsbCkKICAgICAgICAgICAgewogICAgICAgICAgICAgICAgaWYobWVzc2FnZSAhPSBudWxsICYmIG1lc3NhZ2UuTGVuZ3RoID4gMCkKICAgICAgICAgICAgICAgICAgICBfc2VuZFF1ZXVlLkVucXVldWUobWVzc2FnZSk7CiAgICAgICAgICAgIH0KICAgICAgICB9CgogICAgICAgIC8vLyA8c3VtbWFyeT4KICAgICAgICAvLy8g0JzQtdGC0L7QtCDQvtGB0YLQsNC90L7QstC60Lgg0YHQtdGB0YHQuNC4CiAgICAgICAgLy8vIDwvc3VtbWFyeT4KICAgICAgICBwdWJsaWMgdm9pZCBTdG9wKCkKICAgICAgICB7CiAgICAgICAgICAgIF9pc1N0b3BlZCA9IHRydWU7CiAgICAgICAgICAgIF9jbGllbnQuQ2xvc2UoKTsKICAgICAgICB9CgogICAgICAgICNlbmRyZWdpb24gUHVibGljCgogICAgICAgICNyZWdpb24gUHJvdGVjdGVkCgogICAgICAgIC8vLyA8c3VtbWFyeT4KICAgICAgICAvLy8g0JLQuNGA0YLRg9Cw0LvRjNC90YvQuSDQvNC10YLQvtC0INC60L7RgtC+0YvQuSDQvdGD0LbQtdC9INGH0YLQvtCx0Ysg0YHQvtC30LTQsNGC0Ywg0L7QsdGA0LDQsdC+0YLRh9C40Log0YHQtdGB0YHQuNC4LCDQutC+0YLQvtGA0YvQuSDQsdGD0LTQtdGCINGH0YLQvi3RgtC+INC00LXQu9Cw0YLRjCDRgSDQv9GA0LjRiNC10LTRiNC40LzQuCDRgdC+0L7QsdGJ0LXQvdC40Y/QvNC4CiAgICAgICAgLy8vIDwvc3VtbWFyeT4KICAgICAgICAvLy8gPHJldHVybnM+PC9yZXR1cm5zPgogICAgICAgIHByb3RlY3RlZCB2aXJ0dWFsIFRjcFNlc3Npb25IYW5kbGVyQmFzZSBDcmVhdGVIYW5kbGVyKCkKICAgICAgICB7CiAgICAgICAgICAgIHJldHVybiBuZXcgVGNwU2Vzc2lvbkhhbmRsZXJCYXNlKHRoaXMpOwogICAgICAgIH0KCiAgICAgICAgI2VuZHJlZ2lvbgoKICAgICAgICAjcmVnaW9uIFByaXZhdGUKICAgICAgICAvLy8gPHN1bW1hcnk+CiAgICAgICAgLy8vINCf0YDQvtCy0LXRgNC60LAg0L3QtSDQuNGB0YLQtdC60LvQviDQu9C4INCy0YDQtdC80Y8g0LbQuNC30L3QuCDRgdC10YHRgdC40LgKICAgICAgICAvLy8gPC9zdW1tYXJ5PgogICAgICAgIHByaXZhdGUgYm9vbCBpc1RpbW91dFJlYWNoZWQgPT4gKERhdGVUaW1lLk5vdyAtIGxhc3RDb25uZWN0aW9uVGltZUNoZWNrZWQpLlRvdGFsU2Vjb25kcyA+IF9zZXNzaW9uTGlmZXRpbWU7CgogICAgICAgIC8vLyA8c3VtbWFyeT4KICAgICAgICAvLy8g0J7RgdC90L7QstC90L7QuSDQvNC10YLQvtC0INGA0LDQsdC+0YLRiyDRgdC10YHRgdC40LgKICAgICAgICAvLy8gPC9zdW1tYXJ5PgogICAgICAgIHByaXZhdGUgdm9pZCBQcm9jZXNzKCkKICAgICAgICB7CiAgICAgICAgICAgICNyZWdpb24g0JHQtdGB0L/QvtC70LXQt9C90L7QtSDQvtCx0YrRj9GB0L3QtdC90LjQtSDRgtC+0LPQviDQutCw0Log0YDQsNCx0L7RgtCw0LXRgiDRgdC10YHRgdC40Y8KIAogICAgICAgICAgICAjZW5kcmVnaW9uCgogICAgICAgICAgICB0cnkKICAgICAgICAgICAgewogICAgICAgICAgICAgICAgbGFzdENvbm5lY3Rpb25UaW1lQ2hlY2tlZCA9IERhdGVUaW1lLk5vdzsKICAgICAgICAgICAgICAgIF9jbGllbnRTdHJlYW0gPSBfY2xpZW50LkdldFN0cmVhbSgpOwogICAgICAgICAgICAgICAgd2hpbGUoIShfY2FuY2VsbGF0aW9uVG9rZW4uSXNDYW5jZWxsYXRpb25SZXF1ZXN0ZWQgfHwgSXNTdG9wZWQpKQogICAgICAgICAgICAgICAgewogICAgICAgICAgICAgICAgICAgIC8v0JXRgdC70Lgg0LjRgdGC0LXQutC70L4g0LLRgNC10LzRjyDQttC40LfQvdC4INGB0LXRgdGB0LjQuAogICAgICAgICAgICAgICAgICAgIGlmKGlzVGltb3V0UmVhY2hlZCkKICAgICAgICAgICAgICAgICAgICAgICAgYnJlYWs7CgogICAgICAgICAgICAgICAgICAgIC8v0KIu0LouINCyINGC0LXQvtGA0LjQuCDQvdC1INC00L7Qu9C20L3QviDQvdCw0LrQsNC/0LvQuNCy0LDRgtGM0YHRjyDQvNC90L7Qs9C+INGB0L7QvtCx0YnQtdC90LjQuSDQtNC70Y8g0L7RgtC/0YDQsNCy0LrQuCwg0L7RgtC/0YDQsNCy0LvRj9C10Lwg0L/QviDQvtC00L3QvtC80YMg0YHQvtC+0LHRidC10L3QuNGOLCDQsiDQu9GO0LHQvtC8INGB0LvRg9GH0LDQtSwg0L7Rh9C10YDQtdC00Ywg0L7RgtC/0YDQsNCy0LrQuCDQtNC+0LvQttC90LAg0LHRg9C00LXRgiDQt9Cw0LrQsNC90YfQuNCy0LDRgtGM0YHRjyDQsdGL0YHRgtGA0LXQtSDRh9C10Lwg0L/RgNC40YXQvtC00Y/RgiDQvdC+0LLRi9C1CiAgICAgICAgICAgICAgICAgICAgaWYoX3NlbmRRdWV1ZS5Db3VudCA+IDApCiAgICAgICAgICAgICAgICAgICAgewogICAgICAgICAgICAgICAgICAgICAgICBieXRlW10gbXNnOwogICAgICAgICAgICAgICAgICAgICAgICBpZihfc2VuZFF1ZXVlLlRyeURlcXVldWUob3V0IG1zZykpCiAgICAgICAgICAgICAgICAgICAgICAgICAgICBTZW5kTWVzc2FnZShtc2cpOwogICAgICAgICAgICAgICAgICAgIH0KICAgICAgICAgICAgICAgICAgICBHZXRNZXNzYWdlKF9jbGllbnRTdHJlYW0pOwogICAgICAgICAgICAgICAgICAgIC8vVGhyZWFkLlNsZWVwKDEwMCk7CiAgICAgICAgICAgICAgICB9CiAgICAgICAgICAgIH0KICAgICAgICAgICAgY2F0Y2goRXhjZXB0aW9uIGV4KQogICAgICAgICAgICB7CiAgICAgICAgICAgICAgICBTZXNzaW9uRXJyb3I/Lkludm9rZSh0aGlzLCBuZXcgU2VydmVyRXJyb3JBcmdzIHsgRXJyb3JNZXNzYWdlID0gZXguTWVzc2FnZSB9KTsKICAgICAgICAgICAgfQogICAgICAgICAgICBmaW5hbGx5CiAgICAgICAgICAgIHsKICAgICAgICAgICAgICAgIF9jbGllbnQuQ2xvc2UoKTsKICAgICAgICAgICAgfQogICAgICAgICAgICBTdG9wKCk7CiAgICAgICAgfQoKICAgICAgICAvLy8gPHN1bW1hcnk+CiAgICAgICAgLy8vINCc0LXRgtC+0LQg0LTQu9GPINC/0L7Qu9GD0YfQtdC90LjRjyDRgdC+0L7QsdGJ0LXQvdC40Y8g0LjQtyBOZXR3b3JrU3RyZWFtCiAgICAgICAgLy8vIDwvc3VtbWFyeT4KICAgICAgICAvLy8gPHBhcmFtIG5hbWU9InN0cmVhbSI+PC9wYXJhbT4KICAgICAgICAvLy8gPHJldHVybnM+PC9yZXR1cm5zPgogICAgICAgIHByaXZhdGUgYXN5bmMgVGFzazxieXRlW10+IEdldE1lc3NhZ2UoTmV0d29ya1N0cmVhbSBzdHJlYW0pCiAgICAgICAgewogICAgICAgICAgICB1c2luZyhNZW1vcnlTdHJlYW0gbXMgPSBuZXcgTWVtb3J5U3RyZWFtKCkpCiAgICAgICAgICAgIHsKICAgICAgICAgICAgICAgIGJ5dGVbXSBkYXRhID0gbmV3IGJ5dGVbNjRdOyAvLyDQsdGD0YTQtdGAINC00LvRjyDQv9C+0LvRg9GH0LDQtdC80YvRhSDQtNCw0L3QvdGL0YUKICAgICAgICAgICAgICAgIGludCBieXRlcyA9IDA7CiAgICAgICAgICAgICAgICBkbwogICAgICAgICAgICAgICAgewogICAgICAgICAgICAgICAgICAgIGJ5dGVzID0gYXdhaXQgX2NsaWVudFN0cmVhbS5SZWFkQXN5bmMoZGF0YSk7CiAgICAgICAgICAgICAgICAgICAgYXdhaXQgbXMuV3JpdGVBc3luYyhkYXRhLCAwLCBieXRlcyk7CiAgICAgICAgICAgICAgICB9IHdoaWxlKF9jbGllbnRTdHJlYW0uRGF0YUF2YWlsYWJsZSk7CiAgICAgICAgICAgICAgICBpZihtcy5MZW5ndGggPiAwKQogICAgICAgICAgICAgICAgewogICAgICAgICAgICAgICAgICAgIE1lc3NhZ2VSZWNlaXZlZD8uSW52b2tlKHRoaXMsIG5ldyBSZWNlaXZlZE1lc3NhZ2VFdmVudEFyZ3MoKSB7IE1lc3NhZ2UgPSBtcy5Ub0FycmF5KCkgfSk7CiAgICAgICAgICAgICAgICAgICAgbGFzdENvbm5lY3Rpb25UaW1lQ2hlY2tlZCA9IERhdGVUaW1lLk5vdzsKICAgICAgICAgICAgICAgICAgICByZXR1cm4gbXMuVG9BcnJheSgpOwogICAgICAgICAgICAgICAgfQogICAgICAgICAgICB9CiAgICAgICAgICAgIHJldHVybiBudWxsOwogICAgICAgIH0KCiAgICAgICAgLy8vIDxzdW1tYXJ5PgogICAgICAgIC8vLyDQnNC10YLQvtC0INC+0YLQv9GA0LDQstC60Lgg0YHQvtC+0LHRidC10L3QuNGPINC60LvQuNC10L3RgtGDCiAgICAgICAgLy8vIDwvc3VtbWFyeT4KICAgICAgICAvLy8gPHBhcmFtIG5hbWU9Im1lc3NhZ2UiPjwvcGFyYW0+CiAgICAgICAgLy8vIDxyZXR1cm5zPjwvcmV0dXJucz4KICAgICAgICBwcml2YXRlIGFzeW5jIFRhc2sgU2VuZE1lc3NhZ2UoYnl0ZVtdIG1lc3NhZ2UpCiAgICAgICAgewogICAgICAgICAgICBpZihfY2xpZW50U3RyZWFtLkNhbldyaXRlKQogICAgICAgICAgICB7CiAgICAgICAgICAgICAgICBhd2FpdCBfY2xpZW50U3RyZWFtLldyaXRlQXN5bmMobWVzc2FnZSk7CiAgICAgICAgICAgICAgICBsYXN0Q29ubmVjdGlvblRpbWVDaGVja2VkID0gRGF0ZVRpbWUuTm93OwogICAgICAgICAgICB9CiAgICAgICAgfQogICAgICAgICNlbmRyZWdpb24gUHJpdmF0ZQogICAgfQ==