|
@@ -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;
|
|
|
}
|
|
|
|