Code Duplication - daikon-cqrs/message-bus - Measure and Improve Code Quality continuously with Scrutinizer

Code Duplication Length = 15-15 lines in 3 locations

src/Channel/ChannelMap.php 1 location



use Daikon\DataStructures\TypedMapTrait;

final class ChannelMap implements \IteratorAggregate, \Countable
{
    use TypedMapTrait;

    /**
     * @param ChannelInterface[] $channels
     */
    public function __construct(array $channels = [])
    {
        $this->init(array_reduce($channels, function (array $carry, ChannelInterface $channel) {
            $carry[$channel->getKey()] = $channel; // enforce consistent channel keys
            return $carry;
        }, []), ChannelInterface::CLASS);
    }
}


src/Channel/Subscription/SubscriptionMap.php 1 location



use Daikon\DataStructures\TypedMapTrait;

final class SubscriptionMap implements \IteratorAggregate, \Countable
{
    use TypedMapTrait;

    /**
     * @param SubscriptionInterface[] $subscriptions
     */
    public function __construct(array $subscriptions = [])
    {
        $this->init(array_reduce($subscriptions, function (array $carry, SubscriptionInterface $subscription) {
            $carry[$subscription->getKey()] = $subscription; // enforce consistent channel keys
            return $carry;
        }, []), SubscriptionInterface::CLASS);
    }
}


src/Channel/Subscription/Transport/TransportMap.php 1 location



use Daikon\DataStructures\TypedMapTrait;

final class TransportMap implements \IteratorAggregate, \Countable
{
    use TypedMapTrait;

    /**
     * @param TransportInterface[] $transports
     */
    public function __construct(array $transports = [])
    {
        $this->init(array_reduce($transports, function (array $carry, TransportInterface $transport) {
            $carry[$transport->getKey()] = $transport; // enforce consistent channel keys
            return $carry;
        }, []), TransportInterface::CLASS);
    }
}


		@@ 7-21 (lines=15) @@
4
5		use Daikon\DataStructures\TypedMapTrait;
6
7		final class ChannelMap implements \IteratorAggregate, \Countable
8		{
9		use TypedMapTrait;
10
11		/**
12		* @param ChannelInterface[] $channels
13		*/
14		public function __construct(array $channels = [])
15		{
16		$this->init(array_reduce($channels, function (array $carry, ChannelInterface $channel) {
17		$carry[$channel->getKey()] = $channel; // enforce consistent channel keys
18		return $carry;
19		}, []), ChannelInterface::CLASS);
20		}
21		}
22

		@@ 7-21 (lines=15) @@
4
5		use Daikon\DataStructures\TypedMapTrait;
6
7		final class SubscriptionMap implements \IteratorAggregate, \Countable
8		{
9		use TypedMapTrait;
10
11		/**
12		* @param SubscriptionInterface[] $subscriptions
13		*/
14		public function __construct(array $subscriptions = [])
15		{
16		$this->init(array_reduce($subscriptions, function (array $carry, SubscriptionInterface $subscription) {
17		$carry[$subscription->getKey()] = $subscription; // enforce consistent channel keys
18		return $carry;
19		}, []), SubscriptionInterface::CLASS);
20		}
21		}
22

		@@ 7-21 (lines=15) @@
4
5		use Daikon\DataStructures\TypedMapTrait;
6
7		final class TransportMap implements \IteratorAggregate, \Countable
8		{
9		use TypedMapTrait;
10
11		/**
12		* @param TransportInterface[] $transports
13		*/
14		public function __construct(array $transports = [])
15		{
16		$this->init(array_reduce($transports, function (array $carry, TransportInterface $transport) {
17		$carry[$transport->getKey()] = $transport; // enforce consistent channel keys
18		return $carry;
19		}, []), TransportInterface::CLASS);
20		}
21		}
22

daikon-cqrs / message-bus

Code Duplication Length = 15-15 lines in 3 locations

src/Channel/ChannelMap.php 1 location

src/Channel/Subscription/SubscriptionMap.php 1 location

src/Channel/Subscription/Transport/TransportMap.php 1 location