ApiClients\Pusher\Client

Complexity

Total Complexity

4

Size/Duplication

Total Lines	62
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	5

Test Coverage

Coverage

0%

Importance

Changes

0

3 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	5	1
A	channel()	0	9	1
A	channels()	0	22	2

<?php declare(strict_types=1);

namespace ApiClients\Client\Pusher;

use React\EventLoop\Factory;
use React\EventLoop\LoopInterface;
use React\Promise\Deferred;
use Rx\Observer\CallbackObserver;
use function Clue\React\Block\await;
use function React\Promise\all;

final class Client
{
    /**
     * @var LoopInterface
     */
    protected $loop;

    /**
     * @var AsyncClient
     */
    protected $client;

    /**
     * @param string $app Application ID
     */
    public function __construct(string $app)
    {
        $this->loop = Factory::create();
        $this->client = new AsyncClient($this->loop, $app);
    }

    /**
     * @param string $channel Channel to listen on
     * @param callable $listener Listener to call on new messages
     */
    public function channel(string $channel, callable $listener)
    {
        $this->channels(
            [
                $channel,
            ],
            $listener
        );
    }

    /**
     * @param string[] $channels Channels to listen on
     * @param callable $listener Listener to call on new messages
     */
    public function channels(array $channels, callable $listener)
    {
        $promises = [];
        foreach ($channels as $channel) {
            $deferred = new Deferred();
            $this->client->channel($channel)->subscribe(
                new CallbackObserver(
                    $listener,
                    null,
                    function () use ($deferred) {
                        $deferred->resolve();
                    }
                )
            );
            $promises[] = $deferred->promise();
        }

        await(
            all($promises),
            $this->loop
        );
    }
}