Fixed Connection::setStreamTimeout

Author: byrnedo

src/Nats/Connection.php

@@ -449,7 +449,7 @@ public function setStreamTimeout($seconds)
         if ($this->isConnected()) {
             if (is_int($seconds)) {
                 try {
-                    return $this->streamWrapper->setStreamTimeout($this->streamSocket, $seconds);
+                    return stream_set_timeout($this->streamSocket, $seconds);
                 } catch (\Exception $e) {
                     return false;
                 }
@@ -489,4 +489,13 @@ public function close()
         fclose($this->streamSocket);
         $this->streamSocket = null;
     }
+
+
+    /**
+     * @return resource
+     */
+    public function streamSocket()
+    {
+        return $this->streamSocket;
+    }
 }

test/ConnectionTest.php

@@ -161,6 +161,31 @@ function ($message) use ($contentLen) {
 
     }
 
+    /**
+     * Test setting a timeout on the stream
+     * 
+     * @return void
+     */
+    public function testSetStreamTimeout()
+    {
+        $this->c->setStreamTimeout(1);
+        $before = time();
+        $this->c->request(
+            "nonexistantsubject",
+            "test",
+            function($message) {
+                $this->fail("should never have gotten here");
+            }
+        );
+        $timeTaken = time() - $before;
+        
+        $this->assertEquals(1, $timeTaken);
+
+        $meta = stream_get_meta_data($this->c->streamSocket());
+
+        $this->assertTrue($meta["timed_out"]);
+    }
+
     /**
      * Test Unsubscribe command.
      *