ApiClients\Client\Github\Resource\Async\User

Complexity

Total Complexity

3

Size/Duplication

Total Lines	39
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	10

Importance

Changes

0

3 Methods

Rating	Name	Duplication	Size	Complexity
A	refresh()	0	4	1
A	repository()	0	8	1
A	repositories()	0	22	1

<?php declare(strict_types=1);

namespace ApiClients\Client\Github\Resource\Async;

use ApiClients\Foundation\Hydrator\CommandBus\Command\HydrateCommand;
use ApiClients\Foundation\Transport\CommandBus\Command\JsonDecodeCommand;
use ApiClients\Foundation\Transport\CommandBus\Command\SimpleRequestCommand;
use ApiClients\Foundation\Transport\Response;
use ApiClients\Client\Github\CommandBus\Command\IteratePagesCommand;
use ApiClients\Client\Github\Resource\User as BaseUser;
use Psr\Http\Message\ResponseInterface;
use Rx\Observable;
use Rx\ObservableInterface;
use Rx\ObserverInterface;
use Rx\React\Promise;
use Rx\SchedulerInterface;

class User extends BaseUser
{
    public function refresh() : User
    {
        return $this->wait($this->callAsync('refresh'));

The method callAsync() does not seem to exist on object<ApiClients\Client\Github\Resource\Async\User>.

The method wait() does not seem to exist on object<ApiClients\Client\Github\Resource\Async\User>.

    }

    public function repository(string $repository)
    {
        return $this->getCommandBus()->handle(
            new SimpleRequestCommand('repos/' . $this->login() . '/' . $repository)
        )->then(function (ResponseInterface $response) {
            return $this->getCommandBus()->handle(new HydrateCommand('Repository', $response->getBody()->getJson()));

It seems like you code against a concrete implementation and not the interface Psr\Http\Message\StreamInterface as the method getJson() does only exist in the following implementations of said interface: ApiClients\Foundation\Transport\JsonStream.

        });
    }

    public function repositories(): ObservableInterface
    {
        return Observable::create(function (
            ObserverInterface $observer,
            SchedulerInterface $scheduler
        ) {
            $this->getCommandBus()->handle(
                new IteratePagesCommand('users/' . $this->login() . '/repos', $scheduler)

The call to IteratePagesCommand::__construct() has too many arguments starting with $scheduler.

            )->done(function (Observable $observable) use ($observer, $scheduler) {
                $observable->subscribeCallback(
                    [$observer, 'onNext'],
                    [$observer, 'onError'],
                    [$observer, 'onCompleted'],
                    $scheduler
                );
            });
        })->flatMap(function ($repositories) {
            return Observable::fromArray($repositories);
        })->flatMap(function ($repository) {
            return Promise::toObservable($this->getCommandBus()->handle(new HydrateCommand('Repository', $repository)));
        });
    }
}