3.4 Added ambWith example

Froussios · Froussios · commit 5c2ed42e0eea · 2015-05-18T19:10:13.000+02:00
diff --git a/tests/java/itrx/chapter3/combining/AmbTest.java b/tests/java/itrx/chapter3/combining/AmbTest.java
@@ -12,7 +12,7 @@
 
 public class AmbTest {
 
-	public void example() {
+	public void exampleAmb() {
 		Observable.amb(
 		        Observable.timer(100, TimeUnit.MILLISECONDS).map(i -> "First"),
 		        Observable.timer(50, TimeUnit.MILLISECONDS).map(i -> "Second"))
@@ -21,13 +21,22 @@ public void example() {
 		// Second
 	}
 	
+	public void exampleAmbWith() {
+		Observable.timer(100, TimeUnit.MILLISECONDS).map(i -> "First")
+				.ambWith(Observable.timer(50, TimeUnit.MILLISECONDS).map(i -> "Second"))
+				.ambWith(Observable.timer(70, TimeUnit.MILLISECONDS).map(i -> "Third"))
+			.subscribe(System.out::println);
+        
+		// Second
+	}
+	
 	
 	//
 	// Test
 	//
 	
 	@Test
-	public void test() {
+	public void testAmb() {
 		TestSubscriber<String> tester = new TestSubscriber<>();
 		TestScheduler scheduler = Schedulers.test();
 		
@@ -41,5 +50,21 @@ public void test() {
 	    tester.assertTerminalEvent();
 	    tester.assertNoErrors();
 	}
+	
+	@Test
+	public void testAmbWith() {
+		TestSubscriber<String> tester = new TestSubscriber<>();
+		TestScheduler scheduler = Schedulers.test();
+		
+		Observable.timer(100, TimeUnit.MILLISECONDS, scheduler).map(i -> "First")
+				.ambWith(Observable.timer(50, TimeUnit.MILLISECONDS, scheduler).map(i -> "Second"))
+				.ambWith(Observable.timer(70, TimeUnit.MILLISECONDS, scheduler).map(i -> "Third"))
+			.subscribe(tester);
+        
+		scheduler.advanceTimeBy(100, TimeUnit.MILLISECONDS);
+	    tester.assertReceivedOnNext(Arrays.asList("Second"));
+	    tester.assertTerminalEvent();
+	    tester.assertNoErrors();
+	}
 
 }
