@@ -18,7 +18,7 @@ class Connection
1818
1919 /**
2020 * Chunk size in bytes to use when reading with fread.
21- * @var int
21+ * @var integer
2222 */
2323 private $ chunkSize = 1500 ;
2424
@@ -167,7 +167,7 @@ private function receive($len = null)
167167 $ receivedBytes = 0 ;
168168 while ($ receivedBytes < $ len ) {
169169 $ bytesLeft = $ len - $ receivedBytes ;
170- if ( $ bytesLeft < $ this ->chunkSize ) {
170+ if ($ bytesLeft < $ this ->chunkSize ) {
171171 $ chunkSize = $ bytesLeft ;
172172 }
173173
@@ -184,8 +184,8 @@ private function receive($len = null)
184184 /**
185185 * Returns an stream socket to the desired server.
186186 *
187- * @param string $address Server url string.
188- * @param float $timeout Number of seconds until the connect() system call should timeout.
187+ * @param string $address Server url string.
188+ * @param float $timeout Number of seconds until the connect() system call should timeout.
189189 *
190190 * @return resource
191191 * @throws \Exception Exception raised if connection fails.
@@ -368,7 +368,7 @@ private function handlePING()
368368 * @param string $line Message command from Nats.
369369 *
370370 * @return void
371- * @throws Exception
371+ * @throws Exception If subscription not found.
372372 * @codeCoverageIgnore
373373 */
374374 private function handleMSG ($ line )
@@ -471,9 +471,11 @@ public function reconnect()
471471 }
472472
473473 /**
474- * @param integer $chunkSize Set byte chunk len to read when reading from wire
474+ * @param integer $chunkSize Set byte chunk len to read when reading from wire.
475+ * @return void
475476 */
476- public function setChunkSize ($ chunkSize ){
477+ public function setChunkSize ($ chunkSize )
478+ {
477479 $ this ->chunkSize = $ chunkSize ;
478480 }
479481
0 commit comments