LIN3S\SharedKernel\Domain\Event\DomainEventPublisher

Complexity

Total Complexity

9

Size/Duplication

Total Lines	44
Duplicated Lines	0 %

Coupling/Cohesion

Components	2
Dependencies	1

Importance

Changes

0

6 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	4	1
A	__clone()	0	4	1
A	instance()	0	8	2
A	subscriberOfClassName()	0	4	1
A	subscribe()	0	4	1
A	publish()	0	8	3

<?php

/*
 * This file is part of the Shared Kernel library.
 *
 * Copyright (c) 2016-present LIN3S <info@lin3s.com>
 *
 * For the full copyright and license information, please view the LICENSE
 * file that was distributed with this source code.
 */

declare(strict_types=1);

namespace LIN3S\SharedKernel\Domain\Event;

use LIN3S\SharedKernel\Domain\Model\DomainEvent;

/**
 * @author Beñat Espiña <benatespina@gmail.com>
 */
final class DomainEventPublisher
{
    private static $instance;

    private $subscribers;

    private function __construct()
    {
        $this->subscribers = [];
    }

    public function __clone()
    {
        throw new DomainEventPublisherCloningIsNotAllowed();
    }

    public static function instance() : self
    {
        if (null === static::$instance) {

Since LIN3S\SharedKernel\Domain\Event\DomainEventPublisher is declared final, using late-static binding will have no effect. You might want to replace static with self instead.

            static::$instance = new self();

Since LIN3S\SharedKernel\Domain\Event\DomainEventPublisher is declared final, using late-static binding will have no effect. You might want to replace static with self instead.

        }

        return static::$instance;

Since LIN3S\SharedKernel\Domain\Event\DomainEventPublisher is declared final, using late-static binding will have no effect. You might want to replace static with self instead.

    }

    public function subscriberOfClassName(string $className) : DomainEventSubscriber
    {
        return $this->subscribers[$className];
    }

    public function subscribe(DomainEventSubscriber $domainEventSubscriber) : void
    {
        $this->subscribers[get_class($domainEventSubscriber)] = $domainEventSubscriber;
    }

    public function publish(DomainEvent $domainEvent) : void
    {
        foreach ($this->subscribers as $subscriber) {
            if ($subscriber->isSubscribedTo($domainEvent)) {
                $subscriber->handle($domainEvent);
            }
        }
    }
}