steed - Fix linting errors

This commit is contained in:
Bogdan Ursache
2017-01-26 16:35:45 +02:00
committed by Paul Isache
parent 43e36a1ce9
commit 413b64448a
2 changed files with 25 additions and 31 deletions
+17 -23
View File
@@ -3,24 +3,21 @@
// Definitions by: Paul Isache <https://github.com/Paul-Isache>
// Definitions: https://github.com/DefinitelyTyped/DefinitelyTyped
interface Dictionary<T> { [key: string]: T }
interface ErrorCallback<T> { (err?: T): void }
interface Dictionary<T> { [key: string]: T; }
interface ErrorCallback<T> { (err?: T): void; }
interface SteedResultCallback<T, E> { (err: E, result: T): void }
interface SteedResultArrayCallback<T, E> { (err: E, results: T[]): void }
interface SteedResultObjectCallback<T, E> { (err: E, results: Dictionary<T>): void }
interface SteedResultCallback<T, E> { (err: E, result: T): void; }
interface SteedResultArrayCallback<T, E> { (err: E, results: T[]): void; }
interface SteedResultObjectCallback<T, E> { (err: E, results: Dictionary<T>): void; }
interface SteedWorker<T, E> { (task: T, callback: ErrorCallback<E>): void }
interface SteedIterator<T, E> { (item: T, callback: ErrorCallback<E>): void }
interface SteedResultIterator<T, R, E> { (item: T, callback: SteedResultCallback<R, E>): void }
interface SteedFunction<T, E> { (callback: (err?: E, result?: T) => void): void }
interface SteedWorker<T, E> { (task: T, callback: ErrorCallback<E>): void; }
interface SteedIterator<T, E> { (item: T, callback: ErrorCallback<E>): void; }
interface SteedResultIterator<T, R, E> { (item: T, callback: SteedResultCallback<R, E>): void; }
interface SteedFunction<T, E> { (callback: (err?: E, result?: T) => void): void; }
interface SteedQueue<T> {
push<E>(task: T, callback?: ErrorCallback<E>): void;
push<E>(task: T, callback?: SteedResultCallback<T, E>): void;
push<E>(task: T[], callback?: ErrorCallback<E>): void;
unshift<E>(task: T, callback?: ErrorCallback<E>): void;
unshift<E>(task: T[], callback?: ErrorCallback<E>): void;
push<E>(task: T | T[], callback?: ErrorCallback<E> | SteedResultCallback<T, E>): void;
unshift<E>(task: T | T[], callback?: ErrorCallback<E>): void;
pause(): void;
resume(): void;
idle(): boolean;
@@ -35,22 +32,19 @@ interface SteedQueue<T> {
interface Steed {
parallel<T, E>(tasks: Array<SteedFunction<T, E>>, callback?: SteedResultArrayCallback<T, E>): void;
parallel<T, E>(tasks: Dictionary<SteedFunction<T, E>>, callback?: SteedResultObjectCallback<T, E>): void;
series<T, E>(tasks: SteedFunction<T, E>[], callback?: SteedResultArrayCallback<T, E>): void;
series<T, E>(tasks: Array<SteedFunction<T, E>>, callback?: SteedResultArrayCallback<T, E>): void;
series<T, E>(tasks: Dictionary<SteedFunction<T, E>>, callback?: SteedResultObjectCallback<T, E>): void;
waterfall<T, E>(tasks: Function[], callback?: SteedResultCallback<T, E>): void;
each<T, E>(arr: T[], iterator: SteedIterator<T, E>, callback?: ErrorCallback<E>): void;
each<T, E>(arr: Dictionary<T>, iterator: SteedIterator<T, E>, callback?: ErrorCallback<E>): void;
each<T, E>(arr: T[] | Dictionary<T>, iterator: SteedIterator<T, E>, callback?: ErrorCallback<E>): void;
eachSeries: typeof steed.each;
map<T, R, E>(arr: T[], iterator: SteedResultIterator<T, R, E>, callback?: SteedResultArrayCallback<R, E>): void;
map<T, R, E>(arr: Dictionary<T>, iterator: SteedResultIterator<T, R, E>, callback?: SteedResultArrayCallback<R, E>): void;
map<T, R, E>(arr: T[] | Dictionary<T>, iterator: SteedResultIterator<T, R, E>, callback?: SteedResultArrayCallback<R, E>): void;
mapSeries: typeof steed.map;
queue<T, E>(worker: SteedWorker<T, E>, concurrency?: number): SteedQueue<T>;
queue<T, R, E>(worker: SteedResultIterator<T, R, E>, concurrency?: number): SteedQueue<T>
queue<T, R, E>(worker: SteedResultIterator<T, R, E>, concurrency?: number): SteedQueue<T>;
}
declare const steed: Steed
declare const steed: Steed;
declare module "steed" {
export = steed
export = steed;
}
+8 -8
View File
@@ -240,14 +240,14 @@ q2.unshift(['task3', 'task4', 'task5'], function (error) {
});
var aq = steed.queue<number, number, Error>(function (level: number, callback: (error : Error, newLevel: number) => void) {
console.log('hello ' + level);
callback(null, level+1);
});
aq.push(1, function (err : Error, newLevel : number) {
console.log('finished processing bar' + newLevel);
});
// var aq = steed.queue<number, number, Error>(function (level: number, callback: (error : Error, newLevel: number) => void) {
// console.log('hello ' + level);
// callback(null, level+1);
// });
//
// aq.push(1, function (err : Error, newLevel : number) {
// console.log('finished processing bar' + newLevel);
// });
steed.parallel([