Nwidart\LaravelBroadway\Registries\CommandRegistry

Complexity

Total Complexity

4

Size/Duplication

Total Lines	28
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	2

Importance

Changes

0

2 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	4	1
A	subscribe()	0	8	3

<?php namespace Nwidart\LaravelBroadway\Registries;

use Broadway\CommandHandling\CommandBus;

class CommandRegistry extends BaseRegistry implements Registry
{
    /**
     * @var CommandBus
     */
    private $commandBus;

    /**
     * @param CommandBus $commandBus
     */
    public function __construct(CommandBus $commandBus)
    {
        $this->commandBus = $commandBus;
    }

    /**
     * Subscribe the given array of command handlers on the command bus
     * @param array $handlers
     */
    public function subscribe($handlers)
    {
        $handlers = $this->isTraversable($handlers) ? $handlers : [$handlers];

        foreach ($handlers as $commandHandler) {
            $this->commandBus->subscribe($commandHandler);
        }
    }
}