Domain\Eventing\TimeMachine::replayEvents()

Complexity

Conditions	5
Paths	4

Size

Total Lines	22
Code Lines	12

Duplication

Lines	0
Ratio	0 %

Importance

Changes	1
Bugs	0	Features	1

<?php
    public function replayEvents(Identity $identity, $offset = null, $max = null)
    {
        $events = $this->store->getAggregateHistoryFor($identity, $offset, $max);

        foreach ($events as $event) {
            $method = 'when' . ClassToString::short($event);

            if (!isset($this->listeners[$method])) {
                continue;
            }

            if (is_array($this->listeners[$method])) {
                foreach ($this->listeners[$method] as $listener) {
                    call_user_func($listener, $event);
                }
            } else {
                call_user_func($this->listeners[$method], $event);
            }
        }

        return $this;
    }
}