Don't silently swallow predicate errors

Author: chaptastic

src/main/java/com/nurkiewicz/asyncretry/RetryJob.java

@@ -53,11 +53,20 @@ protected void handleThrowable(Throwable t, long duration) {
 
 	protected void handleUserThrowable(Throwable t, long duration) {
 		final AsyncRetryContext nextRetryContext = context.nextRetry(t);
-		if (parent.getRetryPolicy().shouldContinue(nextRetryContext)) {
-			final long delay = calculateNextDelay(duration, nextRetryContext, parent.getBackoff());
-			retryWithDelay(nextRetryContext, delay, duration);
-		} else {
-			logFailure(nextRetryContext, duration);
+
+		try {
+			if (parent.getRetryPolicy().shouldContinue(nextRetryContext)) {
+                final long delay = calculateNextDelay(duration, nextRetryContext, parent.getBackoff());
+                retryWithDelay(nextRetryContext, delay, duration);
+            } else {
+                logFailure(nextRetryContext, duration);
+                future.completeExceptionally(t);
+            }
+		} catch (Throwable t2) {
+			log.error("Threw while trying to decide on retry {} after {}",
+					nextRetryContext.getRetryCount(),
+					duration,
+					t2);
 			future.completeExceptionally(t);
 		}
 	}

src/test/java/com/nurkiewicz/asyncretry/AsyncRetryJobTest.java

@@ -106,6 +106,32 @@ public void shouldRethrowOriginalExceptionFromUserFutureCompletion() throws Exce
 		}
 	}
 
+	@Test
+	public void shouldRethrowOriginalExceptionFromUserFutureCompletionAndAbortWhenTestFails() throws Exception {
+		//given
+		final RetryExecutor executor = new AsyncRetryExecutor(schedulerMock).
+				abortIf(t -> { throw new RuntimeException("test invalid"); });
+
+		given(serviceMock.safeAsync()).willReturn(
+				failedAsync(new SocketException(DON_T_PANIC))
+		);
+
+		//when
+		final CompletableFuture<String> future = executor.getFutureWithRetry(ctx -> serviceMock.safeAsync());
+
+		//then
+		assertThat(future.isCompletedExceptionally()).isTrue();
+
+		try {
+			future.get();
+			failBecauseExceptionWasNotThrown(ExecutionException.class);
+		} catch (ExecutionException e) {
+			final Throwable cause = e.getCause();
+			assertThat(cause).isInstanceOf(SocketException.class);
+			assertThat(cause).hasMessage(DON_T_PANIC);
+		}
+	}
+
 	@Test
 	public void shouldAbortWhenTargetFutureWantsToAbort() throws Exception {
 		//given