Rodenastyle / stream-parser

src/Extensions/ChunkExtension.php

Indentation +71 added lines, -71 removed lines

@@ -13,87 +13,87 @@
  */
 class ChunkExtension implements \Rodenastyle\StreamParser\StreamParserInterface
 {
-    const DEFAULT_CHUNK_SIZE = 5000;
+	const DEFAULT_CHUNK_SIZE = 5000;
 
-    /**
-     * @var \Rodenastyle\StreamParser\StreamParserInterface
-     */
-    private $parser;
-    private $iterationCount = 0;
-    private $chunkSize;
-    /** @var  callable $onChunkCompleteCallback */
-    private $onChunkCompleteCallback;
+	/**
+	 * @var \Rodenastyle\StreamParser\StreamParserInterface
+	 */
+	private $parser;
+	private $iterationCount = 0;
+	private $chunkSize;
+	/** @var  callable $onChunkCompleteCallback */
+	private $onChunkCompleteCallback;
 
-    public function __construct(\Rodenastyle\StreamParser\StreamParserInterface $parser, $chunkSize = self::DEFAULT_CHUNK_SIZE)
-    {
-        $this->parser = $parser;
-        $this->chunkSize = $chunkSize;
-    }
+	public function __construct(\Rodenastyle\StreamParser\StreamParserInterface $parser, $chunkSize = self::DEFAULT_CHUNK_SIZE)
+	{
+		$this->parser = $parser;
+		$this->chunkSize = $chunkSize;
+	}
 
-    public function from(String $source): \Rodenastyle\StreamParser\StreamParserInterface
-    {
-        return $this->parser->from($source);
-    }
+	public function from(String $source): \Rodenastyle\StreamParser\StreamParserInterface
+	{
+		return $this->parser->from($source);
+	}
 
-    public function eachChunk(callable $function): StreamParserInterface
-    {
-        $this->onChunkCompleteCallback = $function;
-        return $this;
-    }
+	public function eachChunk(callable $function): StreamParserInterface
+	{
+		$this->onChunkCompleteCallback = $function;
+		return $this;
+	}
 
-    public function each(callable $function)
-    {
-        if ($this->onChunkCompleteCallback === null) {
-            throw new UndefinedCallbackException("No callback is set on chunk complete");
-        }
-        // decorate function to apply both its behavior and the chunk process
-        $function = function ($collection) use ($function) {
-            $this->iterationCount++;
-            $function($collection);
+	public function each(callable $function)
+	{
+		if ($this->onChunkCompleteCallback === null) {
+			throw new UndefinedCallbackException("No callback is set on chunk complete");
+		}
+		// decorate function to apply both its behavior and the chunk process
+		$function = function ($collection) use ($function) {
+			$this->iterationCount++;
+			$function($collection);
 
-            if ($this->iterationCount % $this->chunkSize === 0) {
-                $this->executeChunkCompleteCallback();
-            }
-        };
-        $this->parser->each($function);
+			if ($this->iterationCount % $this->chunkSize === 0) {
+				$this->executeChunkCompleteCallback();
+			}
+		};
+		$this->parser->each($function);
 
-        // make sure no entry is left out
-        $this->processLastEntries();
-        return $this;
-    }
+		// make sure no entry is left out
+		$this->processLastEntries();
+		return $this;
+	}
 
-    /**
-     * @param $this
-     */
-    protected function executeChunkCompleteCallback()
-    {
-        $this->iterationCount = 0;
-        ($this->onChunkCompleteCallback)();
-    }
+	/**
+	 * @param $this
+	 */
+	protected function executeChunkCompleteCallback()
+	{
+		$this->iterationCount = 0;
+		($this->onChunkCompleteCallback)();
+	}
 
-    protected function processLastEntries()
-    {
-        if ($this->iterationCount % $this->chunkSize !== 0) {
-            $this->executeChunkCompleteCallback();
-        }
-    }
+	protected function processLastEntries()
+	{
+		if ($this->iterationCount % $this->chunkSize !== 0) {
+			$this->executeChunkCompleteCallback();
+		}
+	}
 
 
-    /**
-     * @param int $chunkSize
-     * @return ChunkExtension
-     */
-    public function setChunkSize(int $chunkSize): ChunkExtension
-    {
-        $this->chunkSize = $chunkSize;
-        return $this;
-    }
+	/**
+	 * @param int $chunkSize
+	 * @return ChunkExtension
+	 */
+	public function setChunkSize(int $chunkSize): ChunkExtension
+	{
+		$this->chunkSize = $chunkSize;
+		return $this;
+	}
 
-    /**
-     * @return \Rodenastyle\StreamParser\StreamParserInterface
-     */
-    public function getParser(): \Rodenastyle\StreamParser\StreamParserInterface
-    {
-        return $this->parser;
-    }
+	/**
+	 * @return \Rodenastyle\StreamParser\StreamParserInterface
+	 */
+	public function getParser(): \Rodenastyle\StreamParser\StreamParserInterface
+	{
+		return $this->parser;
+	}
 }
\ No newline at end of file

src/StreamParser.php

Indentation +3 added lines, -3 removed lines

@@ -44,8 +44,8 @@
 		return (new CSVParser())->from($source);
 	}
 
-    private function chunk(StreamParserInterface $parser)
-    {
-        return new ChunkExtension($parser);
+	private function chunk(StreamParserInterface $parser)
+	{
+		return new ChunkExtension($parser);
 	}
 }
\ No newline at end of file