| @@ 14-33 (lines=20) @@ | ||
| 11 | use function React\Promise\reject; |
|
| 12 | use function React\Promise\resolve; |
|
| 13 | ||
| 14 | class Branch extends BaseBranch |
|
| 15 | { |
|
| 16 | /** |
|
| 17 | * @return PromiseInterface |
|
| 18 | */ |
|
| 19 | public function refresh(): PromiseInterface |
|
| 20 | { |
|
| 21 | return Promise::fromObservable(unwrapObservableFromPromise($this->handleCommand( |
|
| 22 | new BranchesCommand($this->repositoryId()) |
|
| 23 | ))->filter(function (BranchInterface $branch) { |
|
| 24 | return $this->id() === $branch->id(); |
|
| 25 | }))->then(function ($branch) { |
|
| 26 | if ($branch === null) { |
|
| 27 | return reject(); |
|
| 28 | } |
|
| 29 | ||
| 30 | return resolve($branch); |
|
| 31 | }); |
|
| 32 | } |
|
| 33 | } |
|
| 34 | ||
| @@ 15-31 (lines=17) @@ | ||
| 12 | use function React\Promise\reject; |
|
| 13 | use function React\Promise\resolve; |
|
| 14 | ||
| 15 | class Cache extends BaseCache |
|
| 16 | { |
|
| 17 | public function refresh(): PromiseInterface |
|
| 18 | { |
|
| 19 | return Promise::fromObservable(unwrapObservableFromPromise($this->handleCommand( |
|
| 20 | new CachesCommand($this->repositoryId()) |
|
| 21 | ))->filter(function (CacheInterface $cache) { |
|
| 22 | return $this->slug() === $cache->slug(); |
|
| 23 | }))->then(function ($cache) { |
|
| 24 | if ($cache === null) { |
|
| 25 | return reject(); |
|
| 26 | } |
|
| 27 | ||
| 28 | return resolve($cache); |
|
| 29 | }); |
|
| 30 | } |
|
| 31 | } |
|
| 32 | ||
| @@ 15-31 (lines=17) @@ | ||
| 12 | use function React\Promise\reject; |
|
| 13 | use function React\Promise\resolve; |
|
| 14 | ||
| 15 | class EnvironmentVariable extends BaseEnvironmentVariable |
|
| 16 | { |
|
| 17 | public function refresh(): PromiseInterface |
|
| 18 | { |
|
| 19 | return Promise::fromObservable(unwrapObservableFromPromise($this->handleCommand( |
|
| 20 | new VarsCommand($this->repositoryId()) |
|
| 21 | ))->filter(function (EnvironmentVariableInterface $var) { |
|
| 22 | return $this->id() === $var->id(); |
|
| 23 | }))->then(function ($var) { |
|
| 24 | if ($var === null) { |
|
| 25 | return reject(); |
|
| 26 | } |
|
| 27 | ||
| 28 | return resolve($var); |
|
| 29 | }); |
|
| 30 | } |
|
| 31 | } |
|
| 32 | ||