ChunkListener::endObject() - Code Metrics - Inspection of "Add chunking and PSR-7 support" - MAXakaWIZARD/JsonCollectionParser - Measure and Improve Code Quality continuously with Scrutinizer

Completed

Pull Request — master (#9)

unknown

created 2020-05-06 17:28 UTC

ChunkListener::endObject() A

↳ Parent: ChunkListener

Complexity

Conditions	3
Paths	4

Size

Total Lines

Duplication

Lines	0
Ratio	0 %

Importance

Changes

Metric	Value
dl	0
loc	15
rs	9.7666
c	0
b	0
f	0
cc	3
nc	4
nop	0

<?php

declare(strict_types=1);

namespace JsonCollectionParser;

class ChunkListener extends Listener
{
    /**
     * 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;

    /**
     * @param int               $size size of the chunk to collect before processing
     * @param callback|callable $callback callback for parsed collection item
     * @param bool              $assoc    When true, returned objects will be converted into associative arrays
     */
    public function __construct(int $size, callable $callback, bool $assoc = true)
    {
        parent::__construct($callback, $assoc);

        $this->size  = $size;
        $this->chunk = [];
    }

    public function endObject(): void
    {
        $this->endCommon();

        $this->objectLevel--;
        if ($this->objectLevel === 0) {
            $obj = array_pop($this->stack);

            $this->chunk[] = reset($obj);
        }

        if (count($this->chunk) === $this->size) {
            $this->processChunk();
        }
    }

    public function endDocument(): void
    {
        $this->processChunk();

        parent::endDocument();
    }

    protected function processChunk(): void
    {
        if (empty($this->chunk)) {
            return;
        }

        call_user_func($this->callback, $this->chunk);

        $this->chunk = [];
    }
}


1			<?php
2
3			declare(strict_types=1);
4
5			namespace JsonCollectionParser;
6
7			class ChunkListener extends Listener
8			{
9			/**
10			* The size of the chunk.
11			*
12			* @var int
13			*/
14			protected $size;
15
16			/**
17			* The callback processing the chunk.
18			*
19			* @var callable
20			*/
21			protected $callback;
22
23			/**
24			* The chunk of objects.
25			*
26			* @var array
27			*/
28			protected $chunk;
29
30			/**
31			* @param int $size size of the chunk to collect before processing
32			* @param callback\|callable $callback callback for parsed collection item
33			* @param bool $assoc When true, returned objects will be converted into associative arrays
34			*/
35			public function __construct(int $size, callable $callback, bool $assoc = true)
36			{
37			parent::__construct($callback, $assoc);
38
39			$this->size = $size;
40			$this->chunk = [];
41			}
42
43			public function endObject(): void
44			{
45			$this->endCommon();
46
47			$this->objectLevel--;
48			if ($this->objectLevel === 0) {
49			$obj = array_pop($this->stack);
50
51			$this->chunk[] = reset($obj);
52			}
53
54			if (count($this->chunk) === $this->size) {
55			$this->processChunk();
56			}
57			}
58
59			public function endDocument(): void
60			{
61			$this->processChunk();
62
63			parent::endDocument();
64			}
65
66			protected function processChunk(): void
67			{
68			if (empty($this->chunk)) {
69			return;
70			}
71
72			call_user_func($this->callback, $this->chunk);
73
74			$this->chunk = [];
75			}
76			}
77

MAXakaWIZARD / JsonCollectionParser

Pull Request — master (#9)

ChunkListener::endObject() A

Complexity

Size

Duplication

Importance

Duplication Side-by-Side

Filter issues like