Nexus\SynchronousNotifier

Complexity

Total Complexity

4

Size/Duplication

Total Lines	15
Duplicated Lines	0 %

Test Coverage

Coverage

100%

Importance

Changes

0

2 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	3	1
A	notify()	0	6	3

<?php

declare(strict_types=1);

namespace Nexus;

use Psr\EventDispatcher\ListenerProviderInterface;
use Psr\EventDispatcher\MessageInterface;
use Psr\EventDispatcher\MessageNotifierInterface;

class SynchronousNotifier implements MessageNotifierInterface
{
    private $listenerProvider;

    public function __construct(ListenerProviderInterface $listenerProvider)
    {
        $this->listenerProvider = $listenerProvider;
    }

    public function notify(MessageInterface $event): void
    {
        foreach ($this->listenerProvider->getListenersForEvent($event) as $listener) {
            try {
                call_user_func($listener, clone$event);
            } catch (\Exception $e) {
                // just prevent this exception from affecting the other messages by catching it quietly
            }
        }
    }
}