onerror

src/retry.spec.ts

@@ -10,7 +10,11 @@ test("does not retry when told not to", async (t) => {
         }
     },
         {},
-        _ => (triesLeft-- > 0),
+        error => {
+            if (triesLeft-- <= 0) {
+                throw error;
+            }
+        },
     );
 
     t.doesNotThrow(retryLogic, "did not retry when no tries were left");
@@ -22,7 +26,7 @@ test("forwards error to caller", async (t) => {
             throw new Error("InnerError");
         },
             {},
-            _ => false,
+            error => { throw error; },
         );
     } catch (err) {
         t.equal(err.message, "InnerError", "error messages match");

src/retry.ts

@@ -16,7 +16,7 @@ export const defaultRetryConfig = {
 export async function retry<T>(
     job: (attempt: number) => PromiseLike<T> | T,
     config: RetryConfig = {},
-    shouldTryAgain = (error: any) => true,
+    onError = (error: any) => undefined as void,
     control?: Promise<void>,
 ): Promise<T> {
     const {
@@ -42,16 +42,19 @@ export async function retry<T>(
         catch (error) {
             if (
                 !(error instanceof CancelError) &&
-                retryAttempt < retryLimit &&
-                shouldTryAgain(error)
+                retryAttempt < retryLimit
             ) {
+                onError(error);
                 error = null;
             }
             if (error) throw error;
         }
 
         // https://aws.amazon.com/blogs/architecture/exponential-backoff-and-jitter/
-        intervalCurrent = Math.min(intervalCap, randomBetween(intervalBase, intervalCurrent * 3));
+        intervalCurrent = Math.min(
+            intervalCap,
+            randomBetween(intervalBase, intervalCurrent * 3),
+        );
         await delay(intervalCurrent, control);
 
         retryAttempt++;