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