Added example defer for 2.1

Froussios · Froussios · commit cf4e31c402aa · 2015-05-12T17:33:27.000+02:00
diff --git a/tests/java/itrx/chapter2/creating/ObservableFactoriesTest.java b/tests/java/itrx/chapter2/creating/ObservableFactoriesTest.java
@@ -1,13 +1,16 @@
 package itrx.chapter2.creating;
 
-import static org.junit.Assert.assertEquals;
+import static org.junit.Assert.*;
 
 import java.util.Arrays;
+import java.util.concurrent.TimeUnit;
 
 import org.junit.Test;
 
 import rx.Observable;
 import rx.observers.TestSubscriber;
+import rx.schedulers.Schedulers;
+import rx.schedulers.TestScheduler;
 
 public class ObservableFactoriesTest {
 
@@ -60,6 +63,23 @@ public void testError() {
 		assertEquals(tester.getOnCompletedEvents().size(), 0);
 	}
 	
+	@Test
+	public void testDefer() {
+		TestScheduler scheduler = Schedulers.test();
+		TestSubscriber<Long> tester1 = new TestSubscriber<>();
+		TestSubscriber<Long> tester2 = new TestSubscriber<>();
+		
+		Observable<Long> now = Observable.defer(() ->
+			Observable.just(scheduler.now()));
+
+		now.subscribe(tester1);
+		scheduler.advanceTimeBy(1000, TimeUnit.MILLISECONDS);
+		now.subscribe(tester2);
+		
+		assertTrue(tester1.getOnNextEvents().get(0) <
+					tester2.getOnNextEvents().get(0));
+	}
+	
 	@Test
 	public void testCreate() {
 		TestSubscriber<String> tester = new TestSubscriber<String>();
