Passed
Pull Request — master (#84)
by Frank
09:49
created

UpcasterChain::upcast()   A

Complexity

Conditions 2
Paths 2

Size

Total Lines 9
Code Lines 4

Duplication

Lines 0
Ratio 0 %

Importance

Changes 1
Bugs 0 Features 0
Metric Value
cc 2
eloc 4
nc 2
nop 1
dl 0
loc 9
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 array $upcasters;
15
16
    public function __construct(Upcaster ...$upcasters)
17
    {
18
        $this->upcasters = $upcasters;
19
    }
20
21
    public function upcast(array $message): Generator
22
    {
23
        $messages = [$message];
24
25
        foreach ($this->upcasters as $upcaster) {
26
            $messages = $this->invokeUpcaster($messages, $upcaster);
27
        }
28
29
        yield from $messages;
30
    }
31
32
    private function invokeUpcaster(iterable $messages, Upcaster $upcaster): Generator
33
    {
34
        foreach ($messages as $message) {
35
            yield from $upcaster->upcast($message);
36
        }
37
    }
38
}
39