2.1 Added from(future) examples

Froussios · Froussios · commit 9c5c39ebaa59 · 2015-05-24T23:27:13.000+02:00
diff --git a/tests/java/itrx/chapter2/creating/FromTest.java b/tests/java/itrx/chapter2/creating/FromTest.java
@@ -2,6 +2,7 @@
 
 import java.util.Arrays;
 import java.util.concurrent.FutureTask;
+import java.util.concurrent.TimeUnit;
 
 import org.junit.Test;
 
@@ -28,6 +29,24 @@ public void exampleFromFuture() {
 		// Received: 21
 		// Completed
 	}
+	
+	public void exampleFromFutureTimeout() {
+		FutureTask<Integer> f = new FutureTask<Integer>(() -> {
+		    Thread.sleep(2000);
+		    return 21;
+		});
+		new Thread(f).start();
+
+		Observable<Integer> values = Observable.from(f, 1000, TimeUnit.MILLISECONDS);
+
+		values.subscribe(
+		    v -> System.out.println("Received: " + v),
+		    e -> System.out.println("Error: " + e),
+		    () -> System.out.println("Completed")
+		);
+		
+		// Error: java.util.concurrent.TimeoutException
+	}
 
 	public void exampleFromArray() {
 		Integer[] is = {1,2,3};
@@ -64,6 +83,24 @@ public void exampleFromIterable() {
 	// Tests
 	//
 	
+	@Test
+	public void testFromFuture() {
+		TestSubscriber<Integer> tester = new TestSubscriber<Integer>();
+		
+		FutureTask<Integer> f = new FutureTask<Integer>(() -> {
+		    return 21;
+		});
+		new Thread(f).start();
+
+		Observable<Integer> values = Observable.from(f);
+
+		values.subscribe(tester);
+		
+		tester.assertReceivedOnNext(Arrays.asList(21));
+		tester.assertNoErrors();
+		tester.assertTerminalEvent();
+	}
+	
 	@Test
 	public void testFromArray() {
 		TestSubscriber<Integer> tester = new TestSubscriber<Integer>();
