StreamClient::requestQuery() - Code Metrics - ytake/php-ksql - Measure and Improve Code Quality continuously with Scrutinizer

StreamClient::requestQuery() A
last analyzed 2018-04-29 18:44 UTC

↳ Parent: StreamClient

Complexity

Conditions	2
Paths	2

Size

Total Lines	12
Code Lines	9

Duplication

Lines	0
Ratio	0 %

Importance

Changes

Metric	Value
dl	0
loc	12
rs	9.4285
c	0
b	0
f	0
cc	2
eloc	9
nc	2
nop	3

<?php
declare(strict_types=1);

namespace Ytake\KsqlClient;

use GuzzleHttp\Client as GuzzleClient;
use GuzzleHttp\ClientInterface;
use Ytake\KsqlClient\Exception\StreamQueryException;
use Ytake\KsqlClient\Query\AbstractStreamQuery;
use Ytake\KsqlClient\Query\QueryInterface;
use Ytake\KsqlClient\Result\AbstractResult;

/**
 * Class StreamClient
 */
final class StreamClient extends RestClient
{
    /**
     * build GuzzleHttp Client
     *
     * @return ClientInterface
     */
    protected function buildClient(): ClientInterface
    {
        return new GuzzleClient([
            'headers' => [
                'User-Agent' => self::USER_AGENT,
                'Accept'     => 'application/json',
            ],
            'stream'  => true,
        ]);
    }

    /**
     * @param QueryInterface $query
     * @param int            $timeout
     * @param bool           $debug
     *
     * @return AbstractResult
     * @throws \GuzzleHttp\Exception\GuzzleException
     */
    public function requestQuery(
        QueryInterface $query,
        int $timeout = 500000,
        bool $debug = false
    ): AbstractResult {
        if ($query instanceof AbstractStreamQuery) {
            return parent::requestQuery($query, $timeout, $debug);
        }
        throw new StreamQueryException(
            "You must extends " . AbstractStreamQuery::class
        );
    }
}


1			<?php
2			declare(strict_types=1);
3
4			namespace Ytake\KsqlClient;
5
6			use GuzzleHttp\Client as GuzzleClient;
7			use GuzzleHttp\ClientInterface;
8			use Ytake\KsqlClient\Exception\StreamQueryException;
9			use Ytake\KsqlClient\Query\AbstractStreamQuery;
10			use Ytake\KsqlClient\Query\QueryInterface;
11			use Ytake\KsqlClient\Result\AbstractResult;
12
13			/**
14			* Class StreamClient
15			*/
16			final class StreamClient extends RestClient
17			{
18			/**
19			* build GuzzleHttp Client
20			*
21			* @return ClientInterface
22			*/
23			protected function buildClient(): ClientInterface
24			{
25			return new GuzzleClient([
26			'headers' => [
27			'User-Agent' => self::USER_AGENT,
28			'Accept' => 'application/json',
29			],
30			'stream' => true,
31			]);
32			}
33
34			/**
35			* @param QueryInterface $query
36			* @param int $timeout
37			* @param bool $debug
38			*
39			* @return AbstractResult
40			* @throws \GuzzleHttp\Exception\GuzzleException
41			*/
42			public function requestQuery(
43			QueryInterface $query,
44			int $timeout = 500000,
45			bool $debug = false
46			): AbstractResult {
47			if ($query instanceof AbstractStreamQuery) {
48			return parent::requestQuery($query, $timeout, $debug);
49			}
50			throw new StreamQueryException(
51			"You must extends " . AbstractStreamQuery::class
52			);
53			}
54			}
55

ytake / php-ksql

StreamClient::requestQuery() A last analyzed 2018-04-29 18:44 UTC

Complexity

Size

Duplication

Importance

Duplication Side-by-Side

Filter issues like

StreamClient::requestQuery() A
last analyzed 2018-04-29 18:44 UTC