From beb6c28c657bf3df610bb356aa1700efc70b016c Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?Serhan=20=C5=9Een?= <mail@serhan-sen.de>
Date: Tue, 16 Dec 2014 20:40:13 +0100
Subject: [PATCH] Apply read_write_timeout to Unix socket connections.

---
 src/Connection/StreamConnection.php | 8 ++++++++
 1 file changed, 8 insertions(+)

diff --git a/src/Connection/StreamConnection.php b/src/Connection/StreamConnection.php
index d74bd6d1..5b8aa3d6 100644
--- a/src/Connection/StreamConnection.php
+++ b/src/Connection/StreamConnection.php
@@ -123,6 +123,14 @@ class StreamConnection extends AbstractConnection
             $this->onConnectionError(trim($errstr), $errno);
         }
 
+        if (isset($parameters->read_write_timeout)) {
+            $rwtimeout = (float) $parameters->read_write_timeout;
+            $rwtimeout = $rwtimeout > 0 ? $rwtimeout : -1;
+            $timeoutSeconds  = floor($rwtimeout);
+            $timeoutUSeconds = ($rwtimeout - $timeoutSeconds) * 1000000;
+            stream_set_timeout($resource, $timeoutSeconds, $timeoutUSeconds);
+        }
+
         return $resource;
     }