int bytesRead = 0;

                                        msg = new byte[4096];
                                        Logging.Write(
                                            "Starting task to wait for Connection Established from server (registration)");
                                        var ar = stream.BeginRead(msg, 0, msg.Length, null, null);
                                        var wh = ar.AsyncWaitHandle;
                                        try
                                        {
                                            connected = true;
                                            if (!ar.AsyncWaitHandle.WaitOne(TimeSpan.FromSeconds(10), false))
                                            {
                                                client.Close();
                                                connected = false;
                                                throw new TimeoutException();
                                            }
                                            bytesRead = stream.EndRead(ar);

                                        }
                                        catch
                                        {
                                            _events.Publish(FormatMessage("SHUTTING DOWN"));
                                        }
                                        finally
                                        {
                                            wh.Close();
                                        }
                                        if (msg[0] == 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();
                                        }