Merge pull request #2 from ultraon/ultraon-patch-2

ultraon · web-flow · commit 0feddc12facb · 2017-08-02T11:59:02.000+03:00
Fixed result output
diff --git a/tests/java/itrx/chapter3/hotandcold/ConnectableObservableExample.java b/tests/java/itrx/chapter3/hotandcold/ConnectableObservableExample.java
@@ -114,7 +114,7 @@ public void exampleRefcount() throws InterruptedException {
 		Thread.sleep(500);
 		Subscription s2 = cold.subscribe(i -> System.out.println("Second: " + i));
 		Thread.sleep(500);
-		System.out.println("Unsubscribe first");
+		System.out.println("Unsubscribe second");
 		s2.unsubscribe();
 		Thread.sleep(500);
 		System.out.println("Unsubscribe first");
@@ -123,15 +123,19 @@ public void exampleRefcount() throws InterruptedException {
 		System.out.println("First connection again");
 		Thread.sleep(500);
 		s1 = cold.subscribe(i -> System.out.println("First: " + i));
+		Thread.sleep(900);
+		System.out.println("Unsubscribe first again");
+		s1.unsubscribe();
 		
 		// First: 0
 		// First: 1
 		// First: 2
 		// Second: 2
 		// First: 3
 		// Second: 3
-		// Unsubscribe first
 		// First: 4
+		// Second: 4
+		// Unsubscribe second
 		// First: 5
 		// First: 6
 		// Unsubscribe first
@@ -140,7 +144,7 @@ public void exampleRefcount() throws InterruptedException {
 		// First: 1
 		// First: 2
 		// First: 3
-		// First: 4
+		// Unsubscribe first again
 	}
 	
 	
