3.4 Added concatWith example

Froussios · Froussios · commit b4380a68af4d · 2015-05-18T19:25:00.000+02:00
diff --git a/tests/java/itrx/chapter3/combining/ConcatTest.java b/tests/java/itrx/chapter3/combining/ConcatTest.java
@@ -45,6 +45,24 @@ public void exampleConcatDynamic() {
 		// Third
 	}
 	
+	public void exampleConcatWith() {
+		Observable<Integer> seq1 = Observable.range(0, 3);
+		Observable<Integer> seq2 = Observable.range(10, 3);
+		Observable<Integer> seq3 = Observable.just(20);
+		
+		seq1.concatWith(seq2)
+			.concatWith(seq3)
+			.subscribe(System.out::println);
+		
+		// 0
+		// 1
+		// 2
+		// 10
+		// 11
+		// 12
+		// 20
+	}
+	
 	
 	//
 	// Tests
@@ -91,5 +109,21 @@ public void testConcatDynamic() {
 		tester.assertTerminalEvent();
 		tester.assertNoErrors();
 	}
-
+	
+	@Test
+	public void testConcatWith() {
+		TestSubscriber<Integer> tester = new TestSubscriber<>();
+		
+		Observable<Integer> seq1 = Observable.range(0, 3);
+		Observable<Integer> seq2 = Observable.range(10, 3);
+		Observable<Integer> seq3 = Observable.just(20);
+		
+		seq1.concatWith(seq2)
+			.concatWith(seq3)
+			.subscribe(tester);
+		
+		tester.assertReceivedOnNext(Arrays.asList(0,1,2,10,11,12,20));
+		tester.assertTerminalEvent();
+		tester.assertNoErrors();
+	}
 }
