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)
            ));
        });
    }
}


		@@ 63-74 (lines=12) @@
60		/**
61		* @return ObservableInterface
62		*/
63		public function queues(): ObservableInterface
64		{
65		return Promise::toObservable($this->client->handle(
66		new SimpleRequestCommand('queues')
67		))->flatMap(function (ResponseInterface $response) {
68		return Observable::fromArray($response->getBody()->getJson());
69		})->flatMap(function ($queue) {
70		return Promise::toObservable($this->client->handle(
71		new HydrateCommand('Queue', $queue)
72		));
73		});
74		}
75
76		/**
77		* @return ObservableInterface
		@@ 79-90 (lines=12) @@
76		/**
77		* @return ObservableInterface
78		*/
79		public function connections(): ObservableInterface
80		{
81		return Promise::toObservable($this->client->handle(
82		new SimpleRequestCommand('connections')
83		))->flatMap(function (ResponseInterface $response) {
84		return Observable::fromArray($response->getBody()->getJson());
85		})->flatMap(function ($connection) {
86		return Promise::toObservable($this->client->handle(
87		new HydrateCommand('Connection', $connection)
88		));
89		});
90		}
91		}
92

php-api-clients / rabbitmq-management

GitHub Access Token became invalid

Code Duplication Length = 12-12 lines in 2 locations

src/AsyncClient.php 2 locations