Merge pull request jhusain#5 from benjchristensen/fixes

Comment Out Ambiguous Overloads and Unit Test Example

Author: jhusain

src/main/java/learnrxjava/examples/ScanVsReduceExample.java

@@ -6,17 +6,17 @@
 
 public class ScanVsReduceExample {
 
-    public static void main(String... args) {
-        Observable.range(0, 10).reduce(() -> new ArrayList<Integer>(), (list, i) -> {
-            list.add(i);
-            return list;
-        }).forEach(System.out::println);
-
-        System.out.println("... vs ...");
-
-        Observable.range(0, 10).scan(() -> new ArrayList<Integer>(), (list, i) -> {
-            list.add(i);
-            return list;
-        }).forEach(System.out::println);
-    }
+//    public static void main(String... args) {
+//        Observable.range(0, 10).reduce(() -> new ArrayList<Integer>(), (list, i) -> {
+//            list.add(i);
+//            return list;
+//        }).forEach(System.out::println);
+//
+//        System.out.println("... vs ...");
+//
+//        Observable.range(0, 10).scan(() -> new ArrayList<Integer>(), (list, i) -> {
+//            list.add(i);
+//            return list;
+//        }).forEach(System.out::println);
+//    }
 }

src/main/java/learnrxjava/examples/UnitTesting.java

@@ -1,5 +1,29 @@
 package learnrxjava.examples;
 
+import java.util.Arrays;
+import java.util.concurrent.TimeUnit;
+
+import rx.Observable;
+import rx.observers.TestSubscriber;
+import rx.schedulers.Schedulers;
+import rx.schedulers.TestScheduler;
+
 public class UnitTesting {
 
+    public static void main(String... args) {
+        TestScheduler test = Schedulers.test();
+        TestSubscriber<String> ts = new TestSubscriber<>();
+
+        Observable.interval(200, TimeUnit.MILLISECONDS, test)
+                .map(i -> {
+                    return i + " value";
+                }).subscribe(ts);
+
+        test.advanceTimeBy(200, TimeUnit.MILLISECONDS);
+        ts.assertReceivedOnNext(Arrays.asList("0 value"));
+
+        test.advanceTimeTo(1000, TimeUnit.MILLISECONDS);
+        ts.assertReceivedOnNext(Arrays.asList("0 value", "1 value", "2 value", "3 value", "4 value"));
+    }
+
 }