Asiries335\redisSteamPhp\StreamGroupConsumer

Complexity

Total Complexity

2

Size/Duplication

Total Lines	30
Duplicated Lines	0 %

Test Coverage

Coverage

0%

Importance

Changes	1
Bugs	0	Features	1

1 Method

Rating	Name	Duplication	Size	Complexity
A	create()	0	18	2

<?php


namespace Asiries335\redisSteamPhp;


use Asiries335\redisSteamPhp\Data\Constants;
use Asiries335\redisSteamPhp\Dto\StreamCommandCallTransporter;

final class StreamGroupConsumer extends RedisStream
{
    /**
     * Create group Consumer
     *
     * @param string $groupName
     * @param bool $isShowFullHistoryStream
     *
     * @return bool
     *
     * @throws \Exception
     */
    public function create(string $groupName, bool $isShowFullHistoryStream = true) : bool
    {
        $transporter = new StreamCommandCallTransporter(
            [
                'command' => Constants::COMMAND_XGROUP,
                'args'    => [
                    'CREATE',
                    $this->_streamName,
                    $groupName,
                    (int) $isShowFullHistoryStream
                ]
            ]
        );

        try {
            return (bool) $this->_client->call($transporter);
        } catch (\Exception $exception) {
            throw $exception;
        }
    }
}