vhad/DefinitelyTyped
1
0
Fork 0
mirror of https://github.com/gosticks/DefinitelyTyped.git synced 2026-07-04 09:10:09 +00:00
Code Issues Actions Packages Projects Releases Wiki Activity

Merge pull request #3378 from horiuchi/asyncblock

Browse Source 
bug fix: asyncblock
This commit is contained in:
Masahiro Wakame
2014-12-27 00:34:56 +09:00
parent af4432fab8 195d5105cc
commit f96983263c
2 changed files with 83 additions and 12 deletions
Download Patch File Download Diff File Expand all files Collapse all files

49
asyncblock/asyncblock-tests.ts
View File

@@ -117,6 +117,55 @@ asyncblock(function(flow) {
})();
// Parallel task rate limiting
(function() {
asyncblock(function(flow) {
flow.queue(function(callback: Function) {
setTimeout(callback, 1000);
});
flow.wait(); //This will wait for about a second
});
asyncblock(function(flow) {
flow.maxParallel = 2;
process.nextTick(function(){
flow.queue(function(callback: Function) {
setTimeout(callback, 1000);
});
flow.queue(function(callback: Function) {
setTimeout(callback, 2000);
});
flow.queue(function(callback: Function) {
setTimeout(callback, 3000);
});
flow.doneAdding();
});
flow.forceWait();
});
asyncblock(function(flow) {
setTimeout(flow.callback(), 1000);
flow.queue(function(callback: Function) {
setTimeout(callback, 1000);
});
flow.queue((callback: (err: any, res: string) => void) => {
callback(null, '');
});
flow.wait();
});
})();
// Task timeouts
(function() {

46
asyncblock/asyncblock.d.ts vendored
View File

@@ -11,23 +11,33 @@ declare module "asyncblock" {
export function nostack<T>(f: (flow: asyncblock.IFlow) => void, callback?: (err: any, res: T) => void): void;
export interface IFlow {
add(responseFormat?: string[]): any;
add(key: string, responseFormat?: string[]): any;
add(key: number, responseFormat?: string[]): any;
add(options: IFlowOptions): any;
callback(responseFormat?: string[]): any;
callback(key: string, responseFormat?: string[]): any;
callback(key: number, responseFormat?: string[]): any;
callback(options: IFlowOptions): any;
sync<T>(f: void): T;
add(responseFormat?: string[]): IExecuteFunction;
add(key: string, responseFormat?: string[]): IExecuteFunction;
add(key: number, responseFormat?: string[]): IExecuteFunction;
add(options: IFlowOptions): IExecuteFunction;
callback(responseFormat?: string[]): IExecuteFunction;
callback(key: string, responseFormat?: string[]): IExecuteFunction;
callback(key: number, responseFormat?: string[]): IExecuteFunction;
callback(options: IFlowOptions): IExecuteFunction;
wait<T>(key?: string): T;
wait<T>(key?: number): T;
get<T>(key: string): T;
set(key: string, responseFormat?: string[]): any;
set(options: IFlowOptions): any;
set(key: string, responseFormat?: string[]): IExecuteFunction;
set(options: IFlowOptions): IExecuteFunction;
del(key: string): void;
sync<T>(task: any): T;
queue(toExecute: IExecuteFunction): void;
queue(key: string, toExecute: IExecuteFunction): void;
queue(key: number, toExecute: IExecuteFunction): void;
queue(responseFormat: string[], toExecute: IExecuteFunction): void;
queue(key: string, responseFormat: string[], toExecute: IExecuteFunction): void;
queue(key: number, responseFormat: string[], toExecute: IExecuteFunction): void;
queue(options: IFlowOptions, toExecute: IExecuteFunction): void;
doneAdding(): void;
forceWait<T>(): T;
maxParallel: number;
errorCallback: (err: any) => void;
taskTimeout: number;
@@ -41,7 +51,19 @@ declare module "asyncblock" {
timeout?: number;
timeoutIsError?: boolean;
dontWait?: boolean;
firstArgIsError?: boolean; // default false
firstArgIsError?: boolean; // default true
}
export interface IExecuteFunction {
<T1, T2, T3>(err: any, res1: T1, res2: T2, res3: T3): any;
<T1, T2>(err: any, res1: T1, res2: T2): any;
<T>(err: any, res: T): any;
(err: any): any;
// firstArgIsError === false
<T1, T2, T3>(res1: T1, res2: T2, res3: T3): any;
<T1, T2>(res1: T1, res2: T2): any;
<T>(res: T): any;
}
}