@@ 24-31 (lines=8) @@ | ||
21 | }); |
|
22 | } |
|
23 | ||
24 | public function job(int $id): ObservableInterface |
|
25 | { |
|
26 | return Promise::toObservable( |
|
27 | $this->getTransport()->request('jobs/' . $id) |
|
28 | )->map(function ($response) { |
|
29 | return $this->getTransport()->getHydrator()->hydrate('Job', $response['job']); |
|
30 | }); |
|
31 | } |
|
32 | } |
|
33 |
@@ 13-22 (lines=10) @@ | ||
10 | ||
11 | class Repository extends BaseRepository |
|
12 | { |
|
13 | public function builds(): Observable |
|
14 | { |
|
15 | return Promise::toObservable( |
|
16 | $this->getTransport()->request('repos/' . $this->slug() . '/builds') |
|
17 | )->flatMap(function ($response) { |
|
18 | return Observable::fromArray($response['builds']); |
|
19 | })->map(function ($build) { |
|
20 | return $this->getTransport()->getHydrator()->hydrate('Build', $build); |
|
21 | }); |
|
22 | } |
|
23 | ||
24 | public function build(int $id): Observable |
|
25 | { |
|
@@ 24-31 (lines=8) @@ | ||
21 | }); |
|
22 | } |
|
23 | ||
24 | public function build(int $id): Observable |
|
25 | { |
|
26 | return Promise::toObservable( |
|
27 | $this->getTransport()->request('repos/' . $this->slug() . '/builds/' . $id) |
|
28 | )->map(function ($response) { |
|
29 | return $this->getTransport()->getHydrator()->hydrate('Build', $response['build']); |
|
30 | }); |
|
31 | } |
|
32 | ||
33 | public function jobs(int $buildId): Observable |
|
34 | { |
|
@@ 40-49 (lines=10) @@ | ||
37 | }); |
|
38 | } |
|
39 | ||
40 | public function commits(): Observable |
|
41 | { |
|
42 | return Promise::toObservable( |
|
43 | $this->getTransport()->request('repos/' . $this->slug() . '/builds') |
|
44 | )->flatMap(function ($response) { |
|
45 | return Observable::fromArray($response['commits']); |
|
46 | })->map(function ($build) { |
|
47 | return $this->getTransport()->getHydrator()->hydrate('Commit', $build); |
|
48 | }); |
|
49 | } |
|
50 | ||
51 | public function events(): Observable |
|
52 | { |