Extraload\Pipeline\QueuedPipeline

Complexity

Total Complexity

2

Size/Duplication

Total Lines	37
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	4

Importance

Changes	5
Bugs	0	Features	1

2 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	12	1
A	process()	0	16	1

<?php

namespace Extraload\Pipeline;

use Extraload\Extractor\QueuedExtractor;
use Extraload\Transformer\QueuedTransformer;
use Extraload\Loader\QueuedLoader;
use Ko\ProcessManager;
use Ko\Process;

class QueuedPipeline implements PipelineInterface
{
    private $extractor;
    private $transformer;
    private $loader;
    private $processManager;

    public function __construct(
        QueuedExtractor $extractor,
        QueuedTransformer $transformer,
        QueuedLoader $loader,
        ProcessManager $processManager
    )
    {
        $this->extractor = $extractor;
        $this->transformer = $transformer;
        $this->loader = $loader;
        $this->processManager = $processManager;
    }

    public function process()
    {
        $this->processManager->fork(function(Process $process) {

The parameter $process is not used and could be removed.

            $this->extractor->extract();
        });

        $this->processManager->fork(function(Process $process) {

The parameter $process is not used and could be removed.

            $this->transformer->transform();
        });

        $this->processManager->fork(function(Process $process) {

The parameter $process is not used and could be removed.

            $this->loader->load();
        });

        $this->processManager->wait();
    }
}