allow for a configurable timeout at getStream method

Author: repejota

src/Connection.php

@@ -148,13 +148,18 @@ private function receive($len = null)
      *
      * @param string $address Server url string.
      *
+     * @param null $timeout
      * @return resource
+     * @throws \Exception
      */
-    private function getStream($address)
+    private function getStream($address, $timeout = null)
     {
-        $fp = stream_socket_client($address, $errno, $errstr, STREAM_CLIENT_CONNECT);
+        if (is_null($timeout)) {
+            $timeout = intval(ini_get('default_socket_timeout'));
+        }
+        $fp = stream_socket_client($address, $errno, $errstr, $timeout, STREAM_CLIENT_CONNECT);
         if (!$fp) {
-            echo '!!!!!!! '.$errstr.' - '.$errno;
+            throw new \Exception($errstr, $errno);
         }
         //stream_set_blocking($fp, 0);
         return $fp;
@@ -173,11 +178,12 @@ public function isConnected()
     /**
      * Connect to server.
      *
-     * @return void
+     * @param null $timeout
+     * @throws \Exception
      */
-    public function connect()
+    public function connect($timeout = null)
     {
-        $this->streamSocket = $this->getStream($this->options->getAddress());
+        $this->streamSocket = $this->getStream($this->options->getAddress(), $timeout);
         $msg = 'CONNECT '.$this->options;
         $this->send($msg);
     }
@@ -268,7 +274,7 @@ private function handleMSG($line)
         } else {
             return new \Exception('not callable');
         }
-
+        
         return;
     }