Skip to content

Navigation Menu

Sign in
Appearance settings

Search code, repositories, users, issues, pull requests...

Provide feedback

We read every piece of feedback, and take your input very seriously.

Saved searches

Use saved searches to filter your results more quickly
Appearance settings

Commit 90d9331

Browse filesBrowse files
rzcoderrzcoder
committed
wip
1 parent ed9f6f5 commit 90d9331
Copy full SHA for 90d9331
Expand file treeCollapse file tree

30 files changed

+396
-34
lines changed

‎.travis.yml

Copy file name to clipboard
+13Lines changed: 13 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,13 @@
1+
language: node_js
2+
node_js:
3+
- '4.0'
4+
- 'stable'
5+
6+
sudo: false
7+
8+
before_install:
9+
- npm install -g npm@latest
10+
- npm install -g grunt-cli
11+
12+
install:
13+
- npm install

‎lib/functions/delay.d.ts

Copy file name to clipboard
+1Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1 @@
1+
export declare function delay(time: number, value?: any): Promise<any>;

‎lib/functions/delay.js

Copy file name to clipboard
+7Lines changed: 7 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,7 @@
1+
"use strict";
2+
function delay(time, value) {
3+
return new Promise(function (resolve) {
4+
setTimeout(resolve.bind(null, value), time);
5+
});
6+
}
7+
exports.delay = delay;

‎lib/functions/links.d.ts

Copy file name to clipboard
+3Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,3 @@
1+
import { Tasks } from "../types";
2+
export declare function all(tasks: Tasks): Promise<any>;
3+
export declare function race(tasks: Tasks): Promise<any>;

‎lib/functions/links.js

Copy file name to clipboard
+9Lines changed: 9 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,9 @@
1+
"use strict";
2+
function all(tasks) {
3+
return Promise.all(tasks);
4+
}
5+
exports.all = all;
6+
function race(tasks) {
7+
return Promise.race(tasks);
8+
}
9+
exports.race = race;

‎lib/functions/parallel.d.ts

Copy file name to clipboardExpand all lines: lib/functions/parallel.d.ts
Whitespace-only changes.

‎lib/functions/parallel.js

Copy file name to clipboard
+13Lines changed: 13 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,13 @@
1+
/*import {
2+
Tasks
3+
} from "../types";
4+
5+
export function parallel(tasks: Tasks, maxThreads: number = tasks.length): Promise<any> {
6+
if (tasks.length === 0) {
7+
return Promise.resolve();
8+
}
9+
10+
return new Promise(function (resolve, reject) {
11+
12+
});
13+
}*/

‎lib/functions/retry.d.ts

Copy file name to clipboard
+2Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,2 @@
1+
import { ITask } from "../types";
2+
export declare function retry(task: ITask, times: number): Promise<any>;

‎lib/functions/retry.js

Copy file name to clipboard
+21Lines changed: 21 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,21 @@
1+
"use strict";
2+
function process(task, times, reasons, resolve, reject) {
3+
task().then(function (result) {
4+
resolve(result);
5+
}).catch(function (reason) {
6+
reasons.push(reason);
7+
if (reasons.length >= times) {
8+
reject(reasons);
9+
}
10+
else {
11+
process(task, times, reasons, resolve, reject);
12+
}
13+
});
14+
}
15+
function retry(task, times) {
16+
return new Promise(function (resolve, reject) {
17+
var reasons = [];
18+
process(task, times, reasons, resolve, reject);
19+
});
20+
}
21+
exports.retry = retry;

‎lib/functions/timeout.d.ts

Copy file name to clipboard
+2Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,2 @@
1+
import { ITask } from "../types";
2+
export declare function timeout(time: number, task: ITask): Promise<any>;

0 commit comments

Comments
0 (0)
Morty Proxy This is a proxified and sanitized view of the page, visit original site.