Fixed defer and create mix-up

Froussios · Froussios · commit f800dc858b31 · 2015-06-18T17:49:16.000+02:00
diff --git a/tests/java/itrx/chapter2/creating/ObservableFactoriesExample.java b/tests/java/itrx/chapter2/creating/ObservableFactoriesExample.java
@@ -60,7 +60,7 @@ public void exampleError() {
 		// Error: java.lang.Exception: Oops
 	}
 	
-	public void exampleDefer() throws InterruptedException {
+	public void exampleShouldDefer() throws InterruptedException {
 		Observable<Long> now = Observable.just(System.currentTimeMillis());
 
 		now.subscribe(System.out::println);
@@ -71,7 +71,7 @@ public void exampleDefer() throws InterruptedException {
 		// 1431443908375
 	}
 	
-	public void exampleCreate() throws InterruptedException {
+	public void exampleDefer() throws InterruptedException {
 		Observable<Long> now = Observable.defer(() ->
         	Observable.just(System.currentTimeMillis()));
 
@@ -83,6 +83,22 @@ public void exampleCreate() throws InterruptedException {
 		// 1431444108858
 	}
 	
+	public void exampleCreate() {
+		Observable<String> values = Observable.create(o -> {
+			o.onNext("Hello");
+			o.onCompleted();
+		});
+		
+		values.subscribe(
+		    v -> System.out.println("Received: " + v),
+		    e -> System.out.println("Error: " + e),
+		    () -> System.out.println("Completed")
+		);
+		
+		// Received: Hello
+		// Completed
+	}
+	
 	
 	//
 	// Tests
@@ -137,6 +153,22 @@ public void testError() {
 		assertEquals(tester.getOnCompletedEvents().size(), 0);
 	}
 	
+	@Test
+	public void testShouldDefer() throws InterruptedException {
+		TestScheduler scheduler = Schedulers.test();
+		TestSubscriber<Long> tester1 = new TestSubscriber<>();
+		TestSubscriber<Long> tester2 = new TestSubscriber<>();
+		
+		Observable<Long> now = Observable.just(scheduler.now());
+
+		now.subscribe(tester1);
+		scheduler.advanceTimeBy(1000, TimeUnit.MILLISECONDS);
+		now.subscribe(tester2);
+		
+		assertEquals(tester1.getOnNextEvents().get(0),
+				tester2.getOnNextEvents().get(0));
+	}
+	
 	@Test
 	public void testDefer() {
 		TestScheduler scheduler = Schedulers.test();
