From c2da06d5c986c328f8d736e810647223d86e12cf Mon Sep 17 00:00:00 2001 From: xing Date: Tue, 29 Jan 2019 11:25:23 +0800 Subject: [PATCH] Update Connection.php number_format return is string --- src/Nats/Connection.php | 12 +++++------- 1 file changed, 5 insertions(+), 7 deletions(-) diff --git a/src/Nats/Connection.php b/src/Nats/Connection.php index 2937a86..6335692 100644 --- a/src/Nats/Connection.php +++ b/src/Nats/Connection.php @@ -172,13 +172,12 @@ public function setChunkSize($chunkSize) * * @return boolean */ - public function setStreamTimeout($seconds) + public function setStreamTimeout($timeout) { if ($this->isConnected() === true) { - if (is_numeric($seconds) === true) { + if (is_numeric($timeout) === true) { try { - $timeout = number_format($seconds, 3); - $seconds = floor($timeout); + $seconds = floor(number_format($timeout, 3)); $microseconds = (($timeout - $seconds) * 1000); return stream_set_timeout($this->streamSocket, $seconds, $microseconds); } catch (\Exception $e) { @@ -249,9 +248,8 @@ function () { if ($fp === false) { throw Exception::forStreamSocketClientError($errstr, $errno); } - - $timeout = number_format($timeout, 3); - $seconds = floor($timeout); + + $seconds = floor(number_format($timeout, 3)); $microseconds = (($timeout - $seconds) * 1000); stream_set_timeout($fp, $seconds, $microseconds);