Modified RetryWhen to match book

Froussios · Froussios · commit c899fadd6bf4 · 2015-06-11T20:56:22.000+02:00
diff --git a/tests/java/itrx/chapter3/error/RetryWhenTest.java b/tests/java/itrx/chapter3/error/RetryWhenTest.java
@@ -1,7 +1,5 @@
 package itrx.chapter3.error;
 
-import static org.junit.Assert.assertEquals;
-
 import java.io.IOException;
 import java.util.Arrays;
 import java.util.concurrent.TimeUnit;
@@ -29,8 +27,7 @@ public void example() {
 		
 		source.retryWhen((o) -> o
 				.take(2)
-				.delay(100, TimeUnit.MILLISECONDS)
-				.concatWith(Observable.error(new Exception("Done"))))
+				.delay(100, TimeUnit.MILLISECONDS))
 			.timeInterval()
 			.subscribe(
 				System.out::println,
@@ -62,14 +59,14 @@ public void test() {
 		source.retryWhen((o) -> o
 				.take(2)
 				.delay(100, TimeUnit.MILLISECONDS, scheduler)
-				.concatWith(Observable.error(new Exception("Done"))), scheduler)
+				, scheduler)
 			.timeInterval(scheduler)
 			.map(i -> i.getIntervalInMilliseconds())
 			.subscribe(intervals);
 		
 		scheduler.advanceTimeBy(200, TimeUnit.MILLISECONDS);
 		intervals.assertReceivedOnNext(Arrays.asList(0L, 0L, 100L, 0L, 100L, 0L));
 		intervals.assertTerminalEvent();
-		assertEquals(1, intervals.getOnErrorEvents().size());
+		intervals.assertNoErrors();
 	}
 }
