From cf84b05077701f5892f3e50b8c1303782519c83e Mon Sep 17 00:00:00 2001
From: Jon Schneider <joschneider@netflix.com>
Date: Fri, 14 Nov 2014 15:27:17 -0800
Subject: [PATCH] Fix ScanVsReduceExample, fix javadocs

---
 .../java/learnrxjava/ObservableExercises.java |  4 +--
 .../examples/ScanVsReduceExample.java         | 25 +++++++++----------
 2 files changed, 14 insertions(+), 15 deletions(-)

diff --git a/src/main/java/learnrxjava/ObservableExercises.java b/src/main/java/learnrxjava/ObservableExercises.java
index 9f7f408..b7827e7 100644
--- a/src/main/java/learnrxjava/ObservableExercises.java
+++ b/src/main/java/learnrxjava/ObservableExercises.java
@@ -38,7 +38,7 @@ public Observable<String> exerciseFilterMap(Observable<Integer> nums) {
     /**
      * Flatten out all video in the stream of Movies into a stream of videoIDs
      * 
-     * @param movieLists
+     * @param movies
      * @return Observable of Integers of Movies.videos.id
      */
     public Observable<Integer> exerciseConcatMap(Observable<Movies> movies) {
@@ -55,7 +55,7 @@ public Observable<Integer> exerciseConcatMap(Observable<Movies> movies) {
      * 
      * We'll see more about this later when we add concurrency.
      * 
-     * @param movieLists
+     * @param movies
      * @return Observable of Integers of Movies.videos.id
      */
     public Observable<Integer> exerciseFlatMap(Observable<Movies> movies) {
diff --git a/src/main/java/learnrxjava/examples/ScanVsReduceExample.java b/src/main/java/learnrxjava/examples/ScanVsReduceExample.java
index acc471f..dd33d1c 100644
--- a/src/main/java/learnrxjava/examples/ScanVsReduceExample.java
+++ b/src/main/java/learnrxjava/examples/ScanVsReduceExample.java
@@ -5,18 +5,17 @@
 import rx.Observable;
 
 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);
 
-//    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);
-//    }
+        System.out.println("... vs ...");
+
+        Observable.range(0, 10).scan(new ArrayList<Integer>(), (list, i) -> {
+            list.add(i);
+            return list;
+        }).forEach(System.out::println);
+    }
 }