Close connection on error

src/Client.php

@@ -60,7 +60,9 @@ public function log(Request $request, Response $response)
     {
         @trigger_error('log() is deprecated since version 0.2 and will be removed in 0.3. Use request(new LogCommand()) instead.', E_USER_DEPRECATED);
 
-        return $this->request(new LogCommand($request, $response));
+        $this->request(new LogCommand($request, $response));
+
+        return true;
     }
 
     public function request(Command\CommandInterface $command)
@@ -90,6 +92,7 @@ private function doRequest(Command\CommandInterface $command)
 
             --$this->connections[$this->currentConnectionName]['retries'];
             $this->currentConnection = null;
+            $this->box('disconnect', null, [$connection]);
 
             return $this->doRequest($command);
         }
@@ -108,6 +111,7 @@ private function doRequest(Command\CommandInterface $command)
 
             --$this->connections[$this->currentConnectionName]['retries'];
             $this->currentConnection = null;
+            $this->box('disconnect', null, [$connection]);
 
             return $this->doRequest($command);
         }
@@ -175,6 +179,11 @@ private function doConnect($options)
         );
     }
 
+    private function disconnect($connection)
+    {
+        fclose($connection);
+    }
+
     private function doSend($connection, $content)
     {
         return $this->fwrite($connection, $content);