src/Resource/Async/Account.php 1 location
|
@@ 13-26 (lines=14) @@
|
10 |
|
use Rx\React\Promise; |
11 |
|
use function ApiClients\Tools\Rx\unwrapObservableFromPromise; |
12 |
|
|
13 |
|
class Account extends BaseAccount |
14 |
|
{ |
15 |
|
/** |
16 |
|
* @return PromiseInterface |
17 |
|
*/ |
18 |
|
public function refresh(): PromiseInterface |
19 |
|
{ |
20 |
|
return Promise::fromObservable(unwrapObservableFromPromise($this->handleCommand( |
21 |
|
new AccountsCommand() |
22 |
|
))->filter(function (AccountInterface $account) { |
23 |
|
return $this->id() === $account->id(); |
24 |
|
})); |
25 |
|
} |
26 |
|
} |
27 |
|
|
src/Resource/Async/Broadcast.php 1 location
|
@@ 12-22 (lines=11) @@
|
9 |
|
use Rx\React\Promise; |
10 |
|
use function ApiClients\Tools\Rx\unwrapObservableFromPromise; |
11 |
|
|
12 |
|
class Broadcast extends BaseBroadcast |
13 |
|
{ |
14 |
|
public function refresh(): PromiseInterface |
15 |
|
{ |
16 |
|
return Promise::fromObservable(unwrapObservableFromPromise($this->handleCommand( |
17 |
|
new BroadcastsCommand() |
18 |
|
))->filter(function (BroadcastInterface $broadcast) { |
19 |
|
return $this->id() === $broadcast->id(); |
20 |
|
})); |
21 |
|
} |
22 |
|
} |
23 |
|
|
src/Resource/Async/Hook.php 1 location
|
@@ 13-23 (lines=11) @@
|
10 |
|
use Rx\React\Promise; |
11 |
|
use function ApiClients\Tools\Rx\unwrapObservableFromPromise; |
12 |
|
|
13 |
|
class Hook extends BaseHook |
14 |
|
{ |
15 |
|
public function refresh(): PromiseInterface |
16 |
|
{ |
17 |
|
return Promise::fromObservable(unwrapObservableFromPromise($this->handleCommand( |
18 |
|
new HooksCommand() |
19 |
|
))->filter(function (HookInterface $hook) { |
20 |
|
return $this->id() === $hook->id(); |
21 |
|
})); |
22 |
|
} |
23 |
|
} |
24 |
|
|