Cerbero\JsonObjects\Listeners\ChunkListener

Complexity

Total Complexity

6

Size/Duplication

Total Lines	74
Duplicated Lines	0 %

Test Coverage

Coverage

66.67%

Importance

Changes

0

4 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	4	1
A	endDocument()	0	8	2
A	processExtractedObject()	0	3	1
A	endObject()	0	7	2

<?php

namespace Cerbero\JsonObjects\Listeners;

/**
 * The chunk listener.
 *
 */
class ChunkListener extends AbstractListener
{
    /**
     * The size of the chunk.
     *
     * @var int
     */
    protected $size;

    /**
     * The callback processing the chunk.
     *
     * @var callable
     */
    protected $callback;

    /**
     * The chunk of objects.
     *
     * @var array
     */
    protected $chunk = [];

    /**
     * Set the dependencies.
     *
     * @param int $size
     * @param callable $callback
     */
    public function __construct(int $size, callable $callback)
    {
        $this->size = $size;
        $this->callback = $callback;
    }

    /**
     * Listen to the end of the object.
     *
     * @return void
     */
    public function endObject() : void
    {
        parent::endObject();

        if (count($this->chunk) === $this->size) {
            call_user_func($this->callback, $this->chunk);
            $this->chunk = [];
        }
    }

    /**
     * Process the given extracted object.
     *
     * @param array $object
     * @return void
     */
    protected function processExtractedObject(array $object) : void
    {
        $this->chunk[] = $object;
    }

    /**
     * Listen to the end of the document.
     *
     * @return void
     */
    public function endDocument() : void
    {
        if (!empty($this->chunk)) {
            call_user_func($this->callback, $this->chunk);
            $this->chunk = [];
        }

        parent::endDocument();
    }
}