refactor: use better errors message

ms-fadaei · Nov 7, 2021 · 778040e · 778040e
1 parent 6662910
commit 778040e
Show file tree

Hide file tree

Showing 3 changed files with 5 additions and 5 deletions.
diff --git a/src/runners/parallel-tasks-runner.ts b/src/runners/parallel-tasks-runner.ts
@@ -26,7 +26,7 @@ export class ParallelTasksRunner<T> extends BaseTasksRunner<T> {
 
   public get(index: number): Promise<T> {
     if (this.status === "open") {
-      return Promise.reject(new Error("Task runner is open"));
+      return Promise.reject(new Error("Task runner not yet started"));
     }
 
     // show error if the index is out of bounds

diff --git a/src/runners/pipeline-tasks-runner.ts b/src/runners/pipeline-tasks-runner.ts
@@ -76,7 +76,7 @@ export class PipelineTasksRunner<T> extends BaseTasksRunner<T> {
 
   public async get(index: number): Promise<T> {
     if (this.status === "open") {
-      return Promise.reject(new Error("Task runner is open"));
+      return Promise.reject(new Error("Task runner is not yet started"));
     }
 
     // show error if the index is out of bounds
@@ -98,7 +98,7 @@ export class PipelineTasksRunner<T> extends BaseTasksRunner<T> {
         const nextTask = taskIterator.next(lastResult);
         lastResult = await nextTask.value;
       } catch {
-        return Promise.reject(new Error("Task not reached"));
+        return Promise.reject(new Error("Task failed before reach"));
       }
     }
 

diff --git a/src/runners/serial-tasks-runner.ts b/src/runners/serial-tasks-runner.ts
@@ -59,7 +59,7 @@ export class SerialTasksRunner<T> extends BaseTasksRunner<T> {
 
   public async get(index: number): Promise<T> {
     if (this.status === "open") {
-      return Promise.reject(new Error("Task runner is open"));
+      return Promise.reject(new Error("Task runner is not yet started"));
     }
 
     // show error if the index is out of bounds
@@ -80,7 +80,7 @@ export class SerialTasksRunner<T> extends BaseTasksRunner<T> {
         const nextTask = taskIterator.next()
         await nextTask.value;
       } catch {
-        return Promise.reject(new Error("Task not reached"));
+        return Promise.reject(new Error("Task failed before reach"));
       }
     }