try
                                        {

                                            var tsk = new Task(async () =>
                                            {
                                                try
                                                {
                                                    bytesRead = await stream.ReadAsync(msg, 0, 4096);
                                                    connected = true;
                                                }
                                                catch (Exception e)
                                                {
                                                    Logging.Write(e.Message);
                                                    stream.Close();
                                                }
                                            });
                                            tsk.Start();
                                            Logging.Write(
                                                "Started task to wait for Connection Established from server (registration)");
                                            Logging.Write("This will sleep for 10 seconds, then validate message.");

                                            Thread.Sleep(10000);
                                        }
                                        catch
                                        {
                                            _events.Publish(FormatMessage("SHUTTING DOWN"));

                                        }
                                        if (bytesRead == 0)
                                        {
                                            _events.Publish(FormatMessage("SHUTTING DOWN"));
                                            connected = false;
                                        }
                                        if (connected)
                                        {
                                            Logging.Write("Message Received: " + _encoder.GetString(msg, 0, bytesRead));
                                            _events.Publish(FormatMessage(_encoder.GetString(msg, 0, bytesRead)));
                                            await HandleClient(client);
                                        }
                                        else
                                        {
                                            stream.Close();
                                            client.Close();
                                        }