@@ -18,7 +18,7 @@ class Connection
18
18
19
19
/**
20
20
* Chunk size in bytes to use when reading with fread.
21
- * @var int
21
+ * @var integer
22
22
*/
23
23
private $ chunkSize = 1500 ;
24
24
@@ -167,7 +167,7 @@ private function receive($len = null)
167
167
$ receivedBytes = 0 ;
168
168
while ($ receivedBytes < $ len ) {
169
169
$ bytesLeft = $ len - $ receivedBytes ;
170
- if ( $ bytesLeft < $ this ->chunkSize ) {
170
+ if ($ bytesLeft < $ this ->chunkSize ) {
171
171
$ chunkSize = $ bytesLeft ;
172
172
}
173
173
@@ -184,8 +184,8 @@ private function receive($len = null)
184
184
/**
185
185
* Returns an stream socket to the desired server.
186
186
*
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.
189
189
*
190
190
* @return resource
191
191
* @throws \Exception Exception raised if connection fails.
@@ -368,7 +368,7 @@ private function handlePING()
368
368
* @param string $line Message command from Nats.
369
369
*
370
370
* @return void
371
- * @throws Exception
371
+ * @throws Exception If subscription not found.
372
372
* @codeCoverageIgnore
373
373
*/
374
374
private function handleMSG ($ line )
@@ -471,9 +471,11 @@ public function reconnect()
471
471
}
472
472
473
473
/**
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
475
476
*/
476
- public function setChunkSize ($ chunkSize ){
477
+ public function setChunkSize ($ chunkSize )
478
+ {
477
479
$ this ->chunkSize = $ chunkSize ;
478
480
}
479
481
0 commit comments