League\Event\BufferedEventDispatcher

Complexity

Total Complexity

10

Size/Duplication

Total Lines	56
Duplicated Lines	28.57 %

Coupling/Cohesion

Components	1
Dependencies	3

Importance

Changes

0

6 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	4	1
A	dispatch()	0	4	1
A	dispatchBufferedEvents()	0	6	2
A	subscribeTo()	8	8	2
A	subscribeOnceTo()	8	8	2
A	subscribeListenersFrom()	0	8	2

<?php

declare(strict_types=1);

namespace League\Event;

use Psr\EventDispatcher\EventDispatcherInterface;

class BufferedEventDispatcher implements EventDispatcherInterface, ListenerAcceptor
{
    use EventGeneratorBehavior {
        recordEvent as protected;
        releaseEvents as protected;
    }

    /**
     * @var EventDispatcherInterface
     */
    private $dispatcher;

    public function __construct(EventDispatcherInterface $dispatcher)
    {
        $this->dispatcher = $dispatcher;
    }

    public function dispatch(object $event): void
    {
        $this->recordEvent($event);
    }

    public function dispatchBufferedEvents(): void
    {
        foreach ($this->releaseEvents() as $event) {
            $this->dispatcher->dispatch($event);
        }
    }

    public function subscribeTo(string $event, callable $listener, int $priority = ListenerPriority::NORMAL): void

This method seems to be duplicated in your project.

    {
        if ( ! $this->dispatcher instanceof ListenerAcceptor) {
            throw UnableToSubscribeListener::becauseTheEventDispatcherDoesNotAcceptListeners($this->dispatcher);
        }

        $this->dispatcher->subscribeTo($event, $listener, $priority);
    }

    public function subscribeOnceTo(string $event, callable $listener, int $priority = ListenerPriority::NORMAL): void

This method seems to be duplicated in your project.

    {
        if ( ! $this->dispatcher instanceof ListenerAcceptor) {
            throw UnableToSubscribeListener::becauseTheEventDispatcherDoesNotAcceptListeners($this->dispatcher);
        }

        $this->dispatcher->subscribeOnceTo($event, $listener, $priority);
    }

    public function subscribeListenersFrom(ListenerSubscriber $subscriber): void
    {
        if ( ! $this->dispatcher instanceof ListenerAcceptor) {
            throw UnableToSubscribeListener::becauseTheEventDispatcherDoesNotAcceptListeners($this->dispatcher);
        }

        $this->dispatcher->subscribeListenersFrom($subscriber);
    }
}