Step 5: Error handling complete

mp911de · mp911de · commit 18a795ee3ef7 · 2017-05-07T18:29:58.000+02:00
diff --git a/reactor/src/test/java/workshop/Step5ErrorHandling.java b/reactor/src/test/java/workshop/Step5ErrorHandling.java
@@ -34,8 +34,7 @@ public void monoShouldEmitAFallbackValueOnError() {
 
 		String recoveryValue = "Recovered!";
 
-		// TODO: Replace this line with a fallback value in an error happens
-		Mono<String> withErrorHandling = failedMono;
+		Mono<String> withErrorHandling = failedMono.onErrorReturn(recoveryValue);
 
 		StepVerifier.create(withErrorHandling).expectNext("Recovered!").verifyComplete();
 	}
@@ -47,8 +46,7 @@ public void monoShouldEmitADeferredFallbackValueOnError() {
 
 		Mono<String> recoveryValue = Mono.just("Recovered!");
 
-		// TODO: Replace this line with a fallback that is computed in a deferred way
-		Mono<String> withErrorHandling = failedMono;
+		Mono<String> withErrorHandling = failedMono.onErrorResume(t -> recoveryValue);
 
 		StepVerifier.create(withErrorHandling).expectNext("Recovered!").verifyComplete();
 	}
@@ -60,8 +58,7 @@ public void monoShouldEmitAFallbackValueIfEmpty() {
 
 		Mono<String> recoveryValue = Mono.just("Recovered!");
 
-		// TODO: Replace this line with a fallback that is computed in a deferred way
-		Mono<String> withErrorHandling = emptyMono;
+		Mono<String> withErrorHandling = emptyMono.switchIfEmpty(recoveryValue);
 
 		StepVerifier.create(withErrorHandling).expectNext("Recovered!").verifyComplete();
 	}
@@ -71,8 +68,7 @@ public void monoShouldTranslateException() {
 
 		Mono<String> failedMono = Mono.error(new IllegalStateException("Something bad happened!"));
 
-		// TODO: Replace this line with a Mono translating IllegalStateException to MyBusinessException
-		Mono<String> withErrorHandling = failedMono;
+		Mono<String> withErrorHandling = failedMono.onErrorMap(MyBusinessException::new);
 
 		StepVerifier.create(withErrorHandling).expectError(MyBusinessException.class).verify();
 	}
