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

ultraon · web-flow · commit 6f963cd6429b · 2017-08-02T12:22:31.000+03:00
Fixed result output
diff --git a/tests/java/itrx/chapter3/hotandcold/MulticastExample.java b/tests/java/itrx/chapter3/hotandcold/MulticastExample.java
@@ -46,7 +46,7 @@ public void exampleMutlicast() 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");
@@ -55,15 +55,19 @@ public void exampleMutlicast() 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
@@ -72,7 +76,7 @@ public void exampleMutlicast() throws InterruptedException {
 		// First: 1
 		// First: 2
 		// First: 3
-		// First: 4
+		// Unsubscribe first again
 	}
 	
 	
