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