2.1 Added alternative Rx contract example

Froussios · Froussios · commit 0194a949c0e0 · 2015-06-18T17:49:14.000+02:00
diff --git a/tests/java/itrx/chapter1/RxContractExample.java b/tests/java/itrx/chapter1/RxContractExample.java
@@ -20,7 +20,24 @@ public void example() {
 
 		// 0
 	}
+	
+	public void examplePrintCompletion() {
+		Subject<Integer, Integer>  values = ReplaySubject.create();
+		values.subscribe(
+		    v -> System.out.println(v),
+		    e -> System.out.println(e),
+		    () -> System.out.println("Completed")
+		);
+		values.onNext(0);
+		values.onNext(1);
+		values.onCompleted();
+		values.onNext(2);
+		
+		// 0
+		// 1
+	}
 
+	
 	//
 	// Test
 	//
@@ -40,5 +57,21 @@ public void test() {
 		tester.assertTerminalEvent();
 		tester.assertNoErrors();
 	}
+	
+	@Test
+	public void testPrintCompletion() {
+		TestSubscriber<Integer> tester = new TestSubscriber<Integer>();
+		
+		Subject<Integer, Integer>  values = ReplaySubject.create();
+		values.subscribe(tester);
+		values.onNext(0);
+		values.onNext(1);
+		values.onCompleted();
+		values.onNext(2);
+		
+		tester.assertReceivedOnNext(Arrays.asList(0,1));
+		tester.assertTerminalEvent();
+		tester.assertNoErrors();
+	}
 
 }
