Merge branch 'master' into dev-1.1

Author: cracksalad

README.md

@@ -1,8 +1,8 @@
 # LargeArrayBuffer
 
-[![License](http://poser.pugx.org/nerou/large-array-buffer/license)](https://packagist.org/packages/nerou/large-array-buffer)
-[![PHP Version Require](http://poser.pugx.org/nerou/large-array-buffer/require/php)](https://packagist.org/packages/nerou/large-array-buffer)
-[![Version](http://poser.pugx.org/nerou/large-array-buffer/version)](https://packagist.org/packages/nerou/large-array-buffer)
+[![License](https://poser.pugx.org/nerou/large-array-buffer/license)](https://packagist.org/packages/nerou/large-array-buffer)
+[![PHP Version Require](https://poser.pugx.org/nerou/large-array-buffer/require/php)](https://packagist.org/packages/nerou/large-array-buffer)
+[![Version](https://poser.pugx.org/nerou/large-array-buffer/version)](https://packagist.org/packages/nerou/large-array-buffer)
 [![Psalm Type Coverage](https://shepherd.dev/github/nerou42/LargeArrayBuffer/coverage.svg)](https://packagist.org/packages/nerou/large-array-buffer)
 
 ## This is for you, if...

bench/LargeArrayBufferBench.php

@@ -24,7 +24,8 @@ private function generateMeasurement(int $index): Measurement {
     return new Measurement(
         (new \DateTimeImmutable())->sub(new \DateInterval('PT'.$index.'H')),
         $index % 500,
-        random_int(-1_000_000, 1_000_000) / 1000);;
+        random_int(-1_000_000, 1_000_000) / 1000
+    );
   }
 
   public function arrayMeasurementsFill(): array {

composer.json

@@ -13,6 +13,7 @@
     ],
     "suggest": {
         "ext-json": "Requirement of toJSONFile() method",
+        "ext-zlib": "To enable support for GZIP compression",
         "ext-lz4": "To enable support of LZ4 compression",
         "ext-igbinary": "To enable support for igbinary serializer",
         "ext-msgpack": "To enable support for msgpack serializer"

src/LargeArrayBuffer.php

@@ -114,17 +114,20 @@ public function rewind(): void {
    * @throws \RuntimeException if unable to read from php://temp
    */
   public function next(): void {
-    if(feof($this->stream) || $this->count === 0) {   // stream is not initialized before first write
+    if(feof($this->stream) || $this->count === $this->index) {   // if nothing to read, no data left
       $this->current = null;
       return;
     }
     $line = fgets($this->stream);
     if($line === false) {
-      throw new \RuntimeException('could not read line from php://temp');
-    }
-    if(strrpos($line, "\n") === strlen($line) - 1){
-      $line = substr($line, 0, strlen($line) - 1);  // cut off line break
+      $this->current = null;
+      if(feof($this->stream)){
+        return;
+      } else {
+        throw new \RuntimeException('could not read line from php://temp at index '.$this->index.' of '.$this->count.' items');
+      }
     }
+    $line = substr($line, 0, strlen($line) - 1);  // cut off line break
     $compressed = stripcslashes($line);
     /** @var string|false $serialized */
     $serialized = match($this->compression){