BatchWriter::flush() - Code Metrics - ddeboer/data-import - Measure and Improve Code Quality continuously with Scrutinizer

BatchWriter::flush() A
last analyzed 2017-08-31 09:23 UTC

↳ Parent: BatchWriter

Complexity

Conditions	3
Paths	4

Size

Total Lines	10
Code Lines	5

Duplication

Lines	0
Ratio	0 %

Code Coverage

Tests	6
CRAP Score	3.1406

Importance

Changes

Metric	Value
dl	0
loc	10
rs	9.4285
c	0
b	0
f	0
ccs	6
cts	8
cp	0.75
cc	3
eloc	5
nc	4
nop	0
crap	3.1406

<?php

namespace Ddeboer\DataImport\Writer;

use Ddeboer\DataImport\Writer;

/**
 * @author Markus Bachmann <[email protected]>
 */
class BatchWriter implements Writer
{
    private $delegate;

    private $size;

    private $queue;

    public function __construct(Writer $delegate, $size = 20)
    {
        $this->delegate = $delegate;
        $this->size = $size;
    }

    public function prepare()
    {
        $this->delegate->prepare();

        $this->queue = new \SplQueue();
        $this->queue->setIteratorMode(\SplDoublyLinkedList::IT_MODE_DELETE);
    }

    public function writeItem(array $item)
    {
        $this->queue->push($item);

        if (count($this->queue) >= $this->size) {
            $this->flush();
        }
    }

    public function finish()
    {
        $this->flush();

        $this->delegate->finish();
    }

    private function flush()
    {
        foreach ($this->queue as $item) {
            $this->delegate->writeItem($item);
        }

        if ($this->delegate instanceof FlushableWriter) {
            $this->delegate->flush();
        }
    }
}


1		<?php
2
3		namespace Ddeboer\DataImport\Writer;
4
5		use Ddeboer\DataImport\Writer;
6
7		/**
8		* @author Markus Bachmann <[email protected]>
9		*/
10		class BatchWriter implements Writer
11		{
12		private $delegate;
13
14		private $size;
15
16		private $queue;
17
18	2	public function __construct(Writer $delegate, $size = 20)
19		{
20	2	$this->delegate = $delegate;
21	2	$this->size = $size;
22	2	}
23
24	2	public function prepare()
25		{
26	2	$this->delegate->prepare();
27
28	2	$this->queue = new \SplQueue();
29	2	$this->queue->setIteratorMode(\SplDoublyLinkedList::IT_MODE_DELETE);
30	2	}
31
32	2	public function writeItem(array $item)
33		{
34	2	$this->queue->push($item);
35
36	2	if (count($this->queue) >= $this->size) {
37	1	$this->flush();
38	1	}
39	2	}
40
41		public function finish()
42		{
43		$this->flush();
44
45		$this->delegate->finish();
46		}
47
48	1	private function flush()
49		{
50	1	foreach ($this->queue as $item) {
51	1	$this->delegate->writeItem($item);
52	1	}
53
54	1	if ($this->delegate instanceof FlushableWriter) {
55		$this->delegate->flush();
56		}
57	1	}
58		}
59

ddeboer / data-import

BatchWriter::flush() A last analyzed 2017-08-31 09:23 UTC

Complexity

Size

Duplication

Code Coverage

Importance

Duplication Side-by-Side

Filter issues like

BatchWriter::flush() A
last analyzed 2017-08-31 09:23 UTC