Passed
Pull Request — master (#84)
by Frank
02:23
created

UpcasterChain::upcast()   A

Complexity

Conditions 2
Paths 2

Size

Total Lines 9
Code Lines 4

Duplication

Lines 0
Ratio 0 %

Code Coverage

Tests 5
CRAP Score 2

Importance

Changes 1
Bugs 0 Features 0
Metric Value
cc 2
eloc 4
nc 2
nop 1
dl 0
loc 9
ccs 5
cts 5
cp 1
crap 2
rs 10
c 1
b 0
f 0
1
<?php
2
3
declare(strict_types=1);
4
5
namespace EventSauce\EventSourcing\Upcasting;
6
7
use Generator;
8
9
class UpcasterChain implements Upcaster
10
{
11
    /**
12
     * @var Upcaster[]
13
     */
14
    private $upcasters;
15
16 1
    public function __construct(Upcaster ...$upcasters)
17
    {
18 1
        $this->upcasters = $upcasters;
19 1
    }
20
21 1
    public function upcast(array $message): Generator
22
    {
23 1
        $messages = [$message];
24
25 1
        foreach ($this->upcasters as $upcaster) {
26 1
            $messages = $this->invokeUpcaster($messages, $upcaster);
27
        }
28
29 1
        yield from $messages;
30 1
    }
31
32 1
    private function invokeUpcaster(iterable $messages, Upcaster $upcaster): Generator
33
    {
34 1
        foreach ($messages as $message) {
35 1
            yield from $upcaster->upcast($message);
36
        }
37 1
    }
38
}
39