@ngx-next/task-runner
Advanced tools
Comparing version 0.7.139-next.60 to 0.7.139-next.61
import * as Listr from 'listr'; | ||
import { Observable } from 'rxjs'; | ||
export declare class NgxTaskRunner { | ||
formatTitle(label: string, output: string): string; | ||
run(tasks: NgxTask[]): Promise<any>; | ||
task(task: Promise<any>): Observable<any>; | ||
task(item: Promise<any>): any; | ||
taskList(tasks: any[]): Listr; | ||
@@ -7,0 +7,0 @@ } |
24
index.js
@@ -5,14 +5,22 @@ "use strict"; | ||
const rxjs_1 = require("rxjs"); | ||
const operators_1 = require("rxjs/operators"); | ||
class NgxTaskRunner { | ||
formatTitle(label, output) { | ||
return `${label} \n ${output} \n`; | ||
} | ||
async run(tasks) { | ||
return new Listr(tasks).run(); | ||
} | ||
task(task) { | ||
return new rxjs_1.Observable(observer => { | ||
Promise.resolve() | ||
.then(() => task) | ||
.then((result) => observer.next(result.stdout)) | ||
.then(() => setTimeout(() => observer.complete(), 300)) | ||
.catch(err => observer.error(new Error(err))); | ||
}); | ||
task(item) { | ||
const output = (ctx, task) => { | ||
return new rxjs_1.Observable(observer => { | ||
Promise.resolve(item) | ||
.then((res) => observer.next(res.stdout)) | ||
.then(() => setTimeout(() => observer.complete(), 300)) | ||
.catch(err => observer.error(new Error(err))); | ||
}).pipe(operators_1.tap((res) => { | ||
task.title = this.formatTitle(task.title, res); | ||
})); | ||
}; | ||
return output; | ||
} | ||
@@ -19,0 +27,0 @@ taskList(tasks) { |
{ | ||
"name": "@ngx-next/task-runner", | ||
"version": "0.7.139-next.60", | ||
"version": "0.7.139-next.61", | ||
"dependencies": { | ||
"@ngx-next/logger": "0.7.139-next.60", | ||
"@ngx-next/logger": "0.7.139-next.61", | ||
"listr": "0.14.3" | ||
@@ -7,0 +7,0 @@ }, |
Sorry, the diff of this file is not supported yet
6053
40
+ Added@ngx-next/logger@0.7.139-next.61(transitive)
- Removed@ngx-next/logger@0.7.139-next.60(transitive)