Merge pull request repejota#55 from dfeyer/task-timeout-microsecond-support

FEATURE: Add microseconds precision for timeout

Author: repejota

src/Connection.php

@@ -97,7 +97,7 @@ public function getSubscriptions()
     /**
      * Connection timeout
      *
-     * @var integer
+     * @var float
      */
     private $timeout = null;
 
@@ -187,7 +187,7 @@ private function receive($len = null)
      * Returns an stream socket to the desired server.
      *
      * @param string  $address Server url string.
-     * @param integer $timeout Number of seconds until the connect() system call should timeout.
+     * @param float $timeout Number of seconds until the connect() system call should timeout.
      *
      * @return resource
      * @throws \Exception Exception raised if connection fails.
@@ -223,7 +223,7 @@ public function isConnected()
     /**
      * Connect to server.
      *
-     * @param integer $timeout Number of seconds until the connect() system call should timeout.
+     * @param float $timeout Number of seconds until the connect() system call should timeout.
      *
      * @throws \Exception Exception raised if connection fails.
      * @return void
@@ -436,7 +436,7 @@ public function wait($quantity = 0)
     /**
      * Set Stream Timeout.
      *
-     * @param integer $seconds Before timeout on stream.
+     * @param float $seconds Before timeout on stream.
      *
      * @return boolean
      */

src/StreamWrapper.php

@@ -10,32 +10,35 @@ class StreamWrapper
     /**
      * Wrapper for stream_socket_client
      *
-     * @param string  $address    Address to connect the socket.
-     * @param integer $errno      Number of error.
-     * @param string  $errstr     Description of error.
-     * @param integer $timeout    Timeout.
+     * @param string $address Address to connect the socket.
+     * @param integer $errno Number of error.
+     * @param string $errstr Description of error.
+     * @param float $timeout Timeout.
      * @param integer $typeStream Type of stream.
      *
      * @return resource
      */
     public function getStreamSocketClient($address, &$errno, &$errstr, $timeout, $typeStream)
     {
         $stream = stream_socket_client($address, $errno, $errstr, $timeout, $typeStream);
-        stream_set_timeout($stream, $timeout);
+        $this->setStreamTimeout($stream, $timeout);
         return $stream;
     }
-    
+
     /**
      * Wrapper for stream_set_timeout
      *
-     * @param mixed   $stream  Stream.
-     * @param integer $seconds Seconds for timeout.
+     * @param mixed $stream Stream.
+     * @param float $seconds Seconds for timeout.
      *
      * @return boolean
      *
-    */
+     */
     public function setStreamTimeout($stream, $seconds)
     {
-        return stream_set_timeout($stream, $seconds);
+        $timeout = number_format($seconds, 3);
+        $seconds = floor($timeout);
+        $microseconds = ($timeout - $seconds) * 1000;
+        return stream_set_timeout($stream, $seconds, $microseconds);
     }
 }