Ytake\KsqlClient\Query\AbstractStreamQuery

Complexity

Total Complexity

1

Size/Duplication

Total Lines	20
Duplicated Lines	0 %

Coupling/Cohesion

Components	0
Dependencies	0

Importance

Changes

0

1 Method

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	5	1

<?php
declare(strict_types=1);

namespace Ytake\KsqlClient\Query;

use Ytake\KsqlClient\StreamConsumable;

/**
 * Class AbstractStreamQuery
 */
abstract class AbstractStreamQuery implements StreamQueryInterface
{
    /** @var string */
    protected $query;

    /** @var StreamConsumable */
    protected $callback;

    /**
     * StreamQuery constructor.
     *
     * @param string           $query
     * @param StreamConsumable $callback
     */
    public function __construct(string $query, StreamConsumable $callback)
    {
        $this->query = $query;
        $this->callback = $callback;
    }
}