WyriHaximus\ApiClient\Resource\CallAsyncTrait

Complexity

Total Complexity

3

Size/Duplication

Total Lines	44
Duplicated Lines	0 %

Coupling/Cohesion

Components	0
Dependencies	3

Importance

Changes

0

4 Methods

Rating	Name	Duplication	Size	Complexity
	getTransport()	0	1	?
A	callAsync()	0	9	1
A	observableToPromise()	0	4	1
A	wait()	0	7	1

<?php
declare(strict_types=1);

namespace ApiClients\Foundation\Resource;

use function Clue\React\Block\await;
use React\Promise\PromiseInterface;
use Rx\ObservableInterface;
use Rx\React\Promise;
use ApiClients\Foundation\Transport\Client;

trait CallAsyncTrait
{
    /**
     * @return Client
     */
    abstract protected function getTransport(): Client;

    /**
     * @param string $function
     * @param array ...$args
     * @return mixed
     */
    protected function callAsync(string $function, ...$args)
    {
        $classChunks = explode('\\', get_class($this));
        $class = array_pop($classChunks);
        return $this->getTransport()
            ->getHydrator()
            ->buildAsyncFromSync($class, $this)
            ->$function(...$args);
    }

    /**
     * @param ObservableInterface $observable
     * @return PromiseInterface
     */
    protected function observableToPromise(ObservableInterface $observable): PromiseInterface
    {
        return Promise::fromObservable($observable);
    }

    /**
     * @param PromiseInterface $promise
     * @return mixed
     * @throws null
     */
    protected function wait(PromiseInterface $promise)
    {
        return await(
            $promise,
            $this->getTransport()->getLoop()
        );
    }
}