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 |
|
|