Destroy session object, removing it from the protocol on end event, r…

…efs #21

src/DNode/DNode.php

@@ -38,9 +38,19 @@ public function connect()
             throw new \Exception("For now we only support TCP connections to a defined port");
         }
 
-        $client = @stream_socket_client("tcp://{$params['host']}:{$params['port']}");
+        $client = stream_socket_client("tcp://{$params['host']}:{$params['port']}");
         if (!$client) {
-            throw new \RuntimeException("No connection to DNode server in tcp://{$params['host']}:{$params['port']}");
+            $e = new \RuntimeException("No connection to DNode server in tcp://{$params['host']}:{$params['port']}");
+            $this->emit('error', array($e));
+
+            if (!count($this->listeners('error'))) {
+                trigger_error((string) $e, E_USER_ERROR);
+            }
+
+            var_dump('sleeping');
+            sleep(1);
+
+            return;
         }
 
         $conn = new Connection($client, $this->loop);

src/DNode/Protocol.php

@@ -16,8 +16,16 @@ public function create()
     {
         // FIXME: Random ID generation, should be unique
         $id = microtime();
-        $this->sessions[$id] = new Session($id, $this->wrapper);
-        return $this->sessions[$id];
+        $session = new Session($id, $this->wrapper);
+
+        $that = $this;
+        $session->on('end', function () use ($that, $id) {
+            return $that->destroy($id);
+        });
+
+        $this->sessions[$id] = $session;
+
+        return $session;
     }
 
     public function destroy($id)

src/DNode/Session.php

@@ -42,6 +42,12 @@ public function start()
     public function end()
     {
         $this->emit('end');
+        $this->removeAllListeners();
+
+        $this->callbacks = array();
+        $this->wrapped = array();
+        $this->remote = null;
+        $this->wrapper = null;
     }
 
     public function request($method, $args)