SlayerBirden\DataFlow\Plumber::pour()

Complexity

Conditions	5
Paths	11

Size

Total Lines

21

Duplication

Lines	0
Ratio	0 %

Code Coverage

Tests	13
CRAP Score	5.0592

Importance

Changes

0

<?php
    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');
    }
}