SlayerBirden\DataFlow\LazyPlumber

Complexity

Total Complexity

3

Size/Duplication

Total Lines	34
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	2

Test Coverage

Coverage

0%

Importance

Changes

0

2 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	9	1
A	pour()	0	8	2

<?php
declare(strict_types=1);

namespace SlayerBirden\DataFlow;

/**
 * This plumber is laze. It delegates pouring to others using emitter;
 * Can be used for concurrency.
 */
class LazyPlumber
{
    /**
     * @var ProviderInterface
     */
    private $provider;
    /**
     * @var PipeLineInterface
     */
    private $pipeLine;
    /**
     * @var EmitterInterface
     */
    private $emitter;

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

    public function pour(): void
    {
        $provider = $this->provider->getCask();
        foreach ($provider as $dataBag) {
            $this->emitter->emit('pour', $dataBag, $this->pipeLine);
        }
        $this->emitter->emit('empty_cask');
    }
}