Plumber::__construct() - Code Metrics - SlayerBirden/dataflow - Measure and Improve Code Quality continuously with Scrutinizer

Plumber::__construct() A
last analyzed 2019-09-19 12:24 UTC

↳ Parent: Plumber

Complexity

Conditions	1
Paths	1

Size

Total Lines

Duplication

Lines	0
Ratio	0 %

Code Coverage

Tests	5
CRAP Score	1

Importance

Changes

Metric	Value
cc	1
nc	1
nop	3
dl	0
loc	6
rs	10
c	0
b	0
f	0
ccs	5
cts	5
cp	1
crap	1

<?php
declare(strict_types=1);

namespace SlayerBirden\DataFlow;

use SlayerBirden\DataFlow\Exception\FlowTerminationException;

class Plumber
{
    /**
     * @var ProviderInterface
     */
    private $source;
    /**
     * @var PipeLineInterface
     */
    private $pipeLine;
    /**
     * @var EmitterInterface
     */
    private $emitter;

    public function __construct(ProviderInterface $source, PipeLineInterface $pipeLine, EmitterInterface $emitter)
    {
        $this->source = $source;
        $this->pipeLine = $pipeLine;
        $this->emitter = $emitter;
    }

    /**
     * Pour source into pipeline.
     */
    public function pour(): void
    {
        $provider = $this->source->getCask();
        foreach ($provider as $dataBag) {
            if ($dataBag instanceof \Throwable) {
                $this->emitter->emit('provider_error', $dataBag->getMessage());
                continue;
            }
            try {
                $this->pipeLine->rewind();
                while ($this->pipeLine->valid()) {
                    $handler = $this->pipeLine->current();
                    $dataBag = $handler->pass($dataBag);
                    $this->pipeLine->next();
                }
            } catch (FlowTerminationException $exception) {
                $this->emitter->emit('valve_closed', $exception->getIdentifier(), $dataBag);
            }
        }
        $this->emitter->emit('empty_cask');
    }
}


1		<?php
2		declare(strict_types=1);
3
4		namespace SlayerBirden\DataFlow;
5
6		use SlayerBirden\DataFlow\Exception\FlowTerminationException;
7
8		class Plumber
9		{
10		/**
11		* @var ProviderInterface
12		*/
13		private $source;
14		/**
15		* @var PipeLineInterface
16		*/
17		private $pipeLine;
18		/**
19		* @var EmitterInterface
20		*/
21		private $emitter;
22
23	4	public function __construct(ProviderInterface $source, PipeLineInterface $pipeLine, EmitterInterface $emitter)
24		{
25	4	$this->source = $source;
26	4	$this->pipeLine = $pipeLine;
27	4	$this->emitter = $emitter;
28	4	}
29
30		/**
31		* Pour source into pipeline.
32		*/
33	4	public function pour(): void
34		{
35	4	$provider = $this->source->getCask();
36	4	foreach ($provider as $dataBag) {
37	4	if ($dataBag instanceof \Throwable) {
38		$this->emitter->emit('provider_error', $dataBag->getMessage());
39		continue;
40		}
41		try {
42	4	$this->pipeLine->rewind();
43	4	while ($this->pipeLine->valid()) {
44	4	$handler = $this->pipeLine->current();
45	4	$dataBag = $handler->pass($dataBag);
46	4	$this->pipeLine->next();
47		}
48	2	} catch (FlowTerminationException $exception) {
49	4	$this->emitter->emit('valve_closed', $exception->getIdentifier(), $dataBag);
50		}
51		}
52	4	$this->emitter->emit('empty_cask');
53	4	}
54		}
55

SlayerBirden / dataflow

Plumber::__construct() A last analyzed 2019-09-19 12:24 UTC

Complexity

Size

Duplication

Code Coverage

Importance

Duplication Side-by-Side

Filter issues like

Plumber::__construct() A
last analyzed 2019-09-19 12:24 UTC