CallAsyncTrait::getTransport()

Completed

Push — master ( ae5fa7...163d7c )

by Cees-Jan

created 2016-07-27 20:12 UTC

↳ Parent: CallAsyncTrait

Size

Total Lines

Duplication

Lines	0
Ratio	0 %

Importance

Changes

Metric	Value
nc	1
dl	0
loc	1
ccs	0
cts	0
cp	0
c	0
b	0
f	0

<?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()
        );
    }
}


1		<?php
2		declare(strict_types=1);
3
4		namespace ApiClients\Foundation\Resource;
5
6		use function Clue\React\Block\await;
7		use React\Promise\PromiseInterface;
8		use Rx\ObservableInterface;
9		use Rx\React\Promise;
10		use ApiClients\Foundation\Transport\Client;
11
12		trait CallAsyncTrait
13		{
14		/**
15		* @return Client
16		*/
17		abstract protected function getTransport(): Client;
18
19		/**
20		* @param string $function
21		* @param array ...$args
22		* @return mixed
23		*/
24	1	protected function callAsync(string $function, ...$args)
25		{
26	1	$classChunks = explode('\\', get_class($this));
27	1	$class = array_pop($classChunks);
28	1	return $this->getTransport()
29	1	->getHydrator()
30	1	->buildAsyncFromSync($class, $this)
31	1	->$function(...$args);
32		}
33
34		/**
35		* @param ObservableInterface $observable
36		* @return PromiseInterface
37		*/
38	1	protected function observableToPromise(ObservableInterface $observable): PromiseInterface
39		{
40	1	return Promise::fromObservable($observable);
41		}
42
43		/**
44		* @param PromiseInterface $promise
45		* @return mixed
46		* @throws null
47		*/
48	1	protected function wait(PromiseInterface $promise)
49		{
50	1	return await(
51		$promise,
52	1	$this->getTransport()->getLoop()
53		);
54		}
55		}
56

php-api-clients / foundation

GitHub Access Token became invalid

Push — master ( ae5fa7...163d7c )

CallAsyncTrait::getTransport()

Size

Duplication

Importance

Duplication Side-by-Side

Filter issues like