diff --git a/src/main/java/learnrxjava/examples/HelloWorld.java b/src/main/java/learnrxjava/examples/HelloWorld.java
index 6694b9f..8f1c220 100644
--- a/src/main/java/learnrxjava/examples/HelloWorld.java
+++ b/src/main/java/learnrxjava/examples/HelloWorld.java
@@ -134,19 +134,16 @@ public void onNext(String t) {
 
         Observable.create(subscriber -> {
             throw new RuntimeException("failed!");
-        }).onErrorReturn(throwable -> {
-            return "fallback value";
-        }).subscribe(System.out::println);
+        }).onErrorReturn(throwable -> "fallback value")
+                .subscribe(System.out::println);
 
         Observable.create(subscriber -> {
             throw new RuntimeException("failed!");
-        }).retryWhen(attempts -> {
-            return attempts.zipWith(Observable.range(1, 3), (throwable, i) -> i)
+        }).retryWhen(attempts -> attempts.zipWith(Observable.range(1, 3), (throwable, i) -> i)
                     .flatMap(i -> {
                         System.out.println("delay retry by " + i + " second(s)");
                         return Observable.timer(i, TimeUnit.SECONDS);
-                    }).concatWith(Observable.error(new RuntimeException("Exceeded 3 retries")));
-        })
+                    }).concatWith(Observable.error(new RuntimeException("Exceeded 3 retries"))))
                 .subscribe(System.out::println, t -> t.printStackTrace());
 
         try {