()
| 126 | .getChannel<BuilderProgressReport>('progress', progressSchema) |
| 127 | .pipe(shareReplay(1)), |
| 128 | stop() { |
| 129 | job.stop(); |
| 130 | |
| 131 | return job.outboundBus |
| 132 | .pipe( |
| 133 | ignoreElements(), |
| 134 | catchError(() => EMPTY), |
| 135 | ) |
| 136 | .toPromise(); |
| 137 | }, |
| 138 | }; |
| 139 | } |
| 140 |