3.2 Simplified forEach test

Froussios · Froussios · commit bb0b9a5e3170 · 2015-05-18T23:39:04.000+02:00
diff --git a/tests/java/itrx/chapter3/leaving/ForEachTest.java b/tests/java/itrx/chapter3/leaving/ForEachTest.java
@@ -122,24 +122,15 @@ public void testBlockingForEach() throws InterruptedException {
 		assertEquals(received, Arrays.asList(0L, 1L, 2L, 3L, 4L, -1L));
 	}
 	
-	@Test
+	@Test(expected = Exception.class)
 	public void testBlockingForEachError() {
-		boolean caughtException = false;
-		
 		Observable<Long> values = Observable.error(new Exception("Oops"));
 
-		try {
-		    values
-		        .take(5)
-		        .toBlocking()
-		        .forEach(
-		            v -> {});
-		}
-		catch (Exception e) {
-		    caughtException = true;
-		}
-
-		assertTrue(caughtException);
+	    values
+	        .take(5)
+	        .toBlocking()
+	        .forEach(
+	            v -> {});
 	}
 
 }
