Merge pull request repejota#48 from dfeyer/task-respect-timeout

TASK: Respect connection timeout on reconnect

Author: repejota

src/Connection.php

@@ -91,6 +91,13 @@ public function getSubscriptions()
      */
     private $options = null;
 
+    /**
+     * Connection timeout
+     *
+     * @var integer
+     */
+    private $timeout = null;
+
     /**
      * Stream File Pointer.
      *
@@ -213,6 +220,7 @@ public function isConnected()
      */
     public function connect($timeout = null)
     {
+        $this->timeout = $timeout;
         $this->streamSocket = $this->getStream($this->options->getAddress(), $timeout);
         $msg = 'CONNECT '.$this->options;
         $this->send($msg);
@@ -441,7 +449,7 @@ public function reconnect()
     {
         $this->reconnects += 1;
         $this->close();
-        $this->connect();
+        $this->connect($this->timeout);
     }
 
     /**