wip

rzcoder · rzcoder · commit ed9f6f5740e7 · 2016-11-01T02:09:33.000+05:00
diff --git a/src/functions/delay.ts b/src/functions/delay.ts
@@ -0,0 +1,5 @@
+export function delay(time: number, value?: any): Promise<any> {
+    return new Promise(function (resolve) {
+        setTimeout(resolve.bind(null, value), time);
+    });
+}
diff --git a/src/functions/parallel.ts b/src/functions/parallel.ts
@@ -0,0 +1,15 @@
+import {
+    Tasks
+} from "../types";
+
+
+export function parallel(tasks: Tasks, maxThreads?: number): Promise<any> {
+    if (!maxThreads) {
+        maxThreads = tasks.length;
+    }
+
+    return new Promise(function (resolve, reject) {
+
+        
+    });
+}
diff --git a/src/functions/retry.ts b/src/functions/retry.ts
@@ -0,0 +1,23 @@
+import {
+    Task
+} from "../types";
+
+function process(task: Task, times: number, reasons: any[], resolve, reject) {
+    task().then((result) => {
+        resolve(result);
+    }).catch((reason) => {
+        reasons.push(reason);
+        if (reasons.length >= times) {
+            reject(reasons);
+        } else {
+            process(task, times, resolve, reject, reasons);
+        }
+    });
+}
+
+export function retry(task: Task, times: number): Promise<any> {
+    return new Promise(function (resolve, reject) {
+        const reasons = [];
+        process(task, times, reasons, resolve, reject);
+    });
+}
diff --git a/src/functions/timeout.ts b/src/functions/timeout.ts
@@ -0,0 +1,16 @@
+import {
+    Task, TimeoutError
+} from "../types";
+
+export function timeout(time: number, task: Task): Promise<any> {
+    return new Promise(function (resolve, reject) {
+        const timeout = setTimeout(reject.bind(null, new TimeoutError()), time);
+        task().then((result) => {
+            resolve(result);
+            clearTimeout(timeout);
+        }, (reason) => {
+            reject(reason);
+            clearTimeout(timeout);
+        });
+    });
+}
diff --git a/src/functions/times.ts b/src/functions/times.ts
@@ -0,0 +1,11 @@
+import {
+    Task
+} from "../types";
+
+
+export function times(task: Task, times: number, stopOnFirstReject: boolean): Promise<any> {
+    return new Promise(function (resolve, reject) {
+        const results = [];
+
+    });
+}
diff --git a/src/functions/waterfall.ts b/src/functions/waterfall.ts
@@ -0,0 +1,17 @@
+import {
+    Tasks
+} from "../types";
+
+export function waterfall(tasks: Tasks): Promise<any> {
+    if (tasks.length === 0) {
+        return Promise.resolve();
+    }
+
+    let promise = tasks[0]();
+    if (tasks.length > 1) {
+        for (const task of tasks) {
+            promise = promise.then(task);
+        }
+    }
+    return promise;
+}
diff --git a/src/prow.ts b/src/prow.ts
@@ -1,17 +1,19 @@
-import {
-    Task, Tasks
+export {
+    Task, Tasks, TimeoutError
 } from "./types";
 
-export function waterfall(tasks: Tasks): Promise<any> {
-    if (tasks.length === 0) {
-        return Promise.resolve();
-    }
-
-    let promise = tasks[0]();
-    if (tasks.length > 1) {
-        for (const task of tasks) {
-            promise = promise.then(task);
-        }
-    }
-    return promise;
-}
+export {delay} from "./functions/delay";
+export {timeout} from "./functions/timeout";
+export {waterfall} from "./functions/waterfall";
+export {retry} from "./functions/retry";
+
+
+
+
+
+
+
+
+
+
+
diff --git a/src/types.ts b/src/types.ts
@@ -1,4 +1,7 @@
 export interface Task {
     (...args: any[]): Promise<any>
 }
-export type Tasks = Task[];
+export type Tasks = Task[];
+
+export class TimeoutError extends Error{
+}
diff --git a/tsconfig.json b/tsconfig.json
@@ -8,6 +8,7 @@
     "module": "commonjs",
     "removeComments": false,
     "lib": [
+      "dom",
       "es5",
       "es2015.promise"
     ]

Original file line number	Diff line number	Diff line change
`@@ -1,4 +1,7 @@`
`1`	`1`	`export interface Task {`
`2`	`2`	`(...args: any[]): Promise<any>`
`3`	`3`	`}`
`4`		`-export type Tasks = Task[];`
	`4`	`+export type Tasks = Task[];`
	`5`	`+`
	`6`	`+export class TimeoutError extends Error{`
	`7`	`+}`
Original file line number	Diff line number	Diff line change
`@@ -8,6 +8,7 @@`
`8`	`8`	`"module": "commonjs",`
`9`	`9`	`"removeComments": false,`
`10`	`10`	`"lib": [`
	`11`	`+ "dom",`
`11`	`12`	`"es5",`
`12`	`13`	`"es2015.promise"`
`13`	`14`	`]`