Code Duplication - php-api-clients/rabbitmq-management - Measure and Improve Code Quality continuously with Scrutinizer

rabbitmq-management

Code Duplication Length = 12-12 lines in 2 locations

src/AsyncClient.php 2 locations


    /**
     * @return ObservableInterface
     */
    public function queues(): ObservableInterface
    {
        return Promise::toObservable($this->client->handle(
            new SimpleRequestCommand('queues')
        ))->flatMap(function (ResponseInterface $response) {
            return Observable::fromArray($response->getBody()->getJson());
        })->flatMap(function ($queue) {
            return Promise::toObservable($this->client->handle(
                new HydrateCommand('Queue', $queue)
            ));
        });
    }

    /**
     * @return ObservableInterface

    /**
     * @return ObservableInterface
     */
    public function connections(): ObservableInterface
    {
        return Promise::toObservable($this->client->handle(
            new SimpleRequestCommand('connections')
        ))->flatMap(function (ResponseInterface $response) {
            return Observable::fromArray($response->getBody()->getJson());
        })->flatMap(function ($connection) {
            return Promise::toObservable($this->client->handle(
                new HydrateCommand('Connection', $connection)
            ));
        });
    }
}


		@@ 84-95 (lines=12) @@
81		/**
82		* @return ObservableInterface
83		*/
84		public function queues(): ObservableInterface
85		{
86		return Promise::toObservable($this->client->handle(
87		new SimpleRequestCommand('queues')
88		))->flatMap(function (ResponseInterface $response) {
89		return Observable::fromArray($response->getBody()->getJson());
90		})->flatMap(function ($queue) {
91		return Promise::toObservable($this->client->handle(
92		new HydrateCommand('Queue', $queue)
93		));
94		});
95		}
96
97		/**
98		* @return ObservableInterface
		@@ 100-111 (lines=12) @@
97		/**
98		* @return ObservableInterface
99		*/
100		public function connections(): ObservableInterface
101		{
102		return Promise::toObservable($this->client->handle(
103		new SimpleRequestCommand('connections')
104		))->flatMap(function (ResponseInterface $response) {
105		return Observable::fromArray($response->getBody()->getJson());
106		})->flatMap(function ($connection) {
107		return Promise::toObservable($this->client->handle(
108		new HydrateCommand('Connection', $connection)
109		));
110		});
111		}
112		}
113

php-api-clients / rabbitmq-management

GitHub Access Token became invalid

Code Duplication Length = 12-12 lines in 2 locations

src/AsyncClient.php 2 locations