Async: adds errorFilter to async retry (#35231)

This commit is contained in:
Arsalan Ahmad
2019-05-08 11:12:51 -07:00
committed by Jesse Trinity
parent cb425140db
commit 86f8676e7d
2 changed files with 3 additions and 1 deletions
+2 -1
View File
@@ -197,7 +197,8 @@ export function autoInject<E = Error>(tasks: any, callback?: AsyncResultCallback
export function retry<T, E = Error>(
opts: number | {
times: number,
interval: number | ((retryCount: number) => number)
interval: number | ((retryCount: number) => number),
errorFilter?: (error: Error) => boolean
},
task: (callback: AsyncResultCallback<T, E>, results: any) => void,
callback: AsyncResultCallback<any, E>
+1
View File
@@ -300,6 +300,7 @@ async.auto<A>({
async.retry(3, (callback, results) => { }, (err, result) => { });
async.retry({ times: 3, interval: 200 }, (callback, results) => { }, (err, result) => { });
async.retry({ times: 3, interval: (retryCount) => 200 * retryCount }, (callback, results) => { }, (err, result) => { });
async.retry({ times: 3, interval: 200, errorFilter: (err) => true }, (callback, results) => { }, (err, result) => { });
async.parallel([
(callback: (err: Error, val: string) => void) => { },