Observable.from with scheduler

Fixed blocking test in ObservableWindowTest

Author: AppliedDuality

rxjava-core/src/main/java/rx/Observable.java

@@ -1034,11 +1034,6 @@ public static <T> Observable<T> from(T t1, T t2, T t3, T t4, T t5, T t6, T t7, T
      * <p>
      * <img width="640" src="https://raw.github.com/wiki/Netflix/RxJava/images/rx-operators/from.png">
      * <p>
-     * Note: the items will be immediately emitted each time an {@link Observer}
-     * subscribes. Since this occurs before the {@link Subscription} is
-     * returned, it is not possible to unsubscribe from the sequence before it
-     * completes.
-     * 
      * @param t1 first item
      * @param t2 second item
      * @param t3 third item
@@ -1066,11 +1061,6 @@ public static <T> Observable<T> from(T t1, T t2, T t3, T t4, T t5, T t6, T t7, T
      * <p>
      * <img width="640" src="https://raw.github.com/wiki/Netflix/RxJava/images/rx-operators/range.png">
      * <p>
-     * Note: the entire range is immediately emitted each time an
-     * {@link Observer} subscribes. Since this occurs before the
-     * {@link Subscription} is returned, it is not possible to unsubscribe from
-     * the sequence before it completes.
-     * 
      * @param start the value of the first Integer in the sequence
      * @param count the number of sequential Integers to generate
      * @return an Observable that emits a range of sequential Integers

rxjava-core/src/test/java/rx/ObservableWindowTests.java

@@ -30,23 +30,6 @@ public class ObservableWindowTests {
     @Test
     public void testWindow() {
         final ArrayList<List<Integer>> lists = new ArrayList<List<Integer>>();
-        /*
-        Observable.from(1, 2, 3, 4, 5, 6)
-                .window(3).map(new Func1<Observable<Integer>, List<Integer>>() {
-
-                    @Override
-                    public List<Integer> call(Observable<Integer> o) {
-                        return o.toList().toBlockingObservable().single();
-                    }
-
-                }).toBlockingObservable().forEach(new Action1<List<Integer>>() {
-
-                    @Override
-                    public void call(List<Integer> t) {
-                        lists.add(t);
-                    }
-                });
-        */
 
         Observable.concat(Observable.from(1, 2, 3, 4, 5, 6).window(3).map(new Func1<Observable<Integer>, Observable<List<Integer>>>() {
             @Override