creating test classes on test source folder

Author: Pedro Viegas

rxjava-core/src/test/java/rx/concurrency/TestSchedulers.java renamed to rxjava-core/src/test/java/rx/SchedulersTest.java

@@ -1,44 +1,41 @@
 /**
  * Copyright 2013 Netflix, Inc.
- * 
+ *
  * Licensed under the Apache License, Version 2.0 (the "License");
  * you may not use this file except in compliance with the License.
  * You may obtain a copy of the License at
- * 
+ *
  * http://www.apache.org/licenses/LICENSE-2.0
- * 
+ *
  * Unless required by applicable law or agreed to in writing, software
  * distributed under the License is distributed on an "AS IS" BASIS,
  * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package rx.concurrency;
-
-import static org.junit.Assert.*;
-
-import java.util.Date;
-import java.util.concurrent.CountDownLatch;
-import java.util.concurrent.TimeUnit;
-import java.util.concurrent.atomic.AtomicBoolean;
-import java.util.concurrent.atomic.AtomicInteger;
-import java.util.concurrent.atomic.AtomicReference;
+package rx;
 
 import org.junit.Test;
-
-import rx.Observable;
 import rx.Observable.OnSubscribeFunc;
-import rx.Observer;
-import rx.Scheduler;
-import rx.Subscription;
+import rx.concurrency.Schedulers;
+import rx.concurrency.TestScheduler;
 import rx.subscriptions.BooleanSubscription;
 import rx.subscriptions.Subscriptions;
 import rx.util.functions.Action0;
 import rx.util.functions.Action1;
 import rx.util.functions.Func1;
 import rx.util.functions.Func2;
 
-public class TestSchedulers {
+import java.util.Date;
+import java.util.concurrent.CountDownLatch;
+import java.util.concurrent.TimeUnit;
+import java.util.concurrent.atomic.AtomicBoolean;
+import java.util.concurrent.atomic.AtomicInteger;
+import java.util.concurrent.atomic.AtomicReference;
+
+import static org.junit.Assert.*;
+
+public class SchedulersTest {
 
     @Test
     public void testComputationThreadPool1() {
@@ -447,18 +444,18 @@ public void testSubscribeOnNestedConcurrency() throws InterruptedException {
         Observable<String> o = Observable.from("one", "two", "three", "four", "five", "six", "seven", "eight", "nine", "ten")
                 .mapMany(new Func1<String, Observable<String>>() {
 
-                    @Override
-                    public Observable<String> call(final String v) {
-                        return Observable.create(new OnSubscribeFunc<String>() {
-
-                            @Override
-                            public Subscription onSubscribe(final Observer<? super String> observer) {
-                                observer.onNext("value_after_map-" + v);
-                                observer.onCompleted();
-                                return Subscriptions.empty();
-                            }
-                        }).subscribeOn(Schedulers.newThread()); // subscribe on a new thread
-                    }
+                  @Override
+                  public Observable<String> call(final String v) {
+                    return Observable.create(new OnSubscribeFunc<String>() {
+
+                      @Override
+                      public Subscription onSubscribe(final Observer<? super String> observer) {
+                        observer.onNext("value_after_map-" + v);
+                        observer.onCompleted();
+                        return Subscriptions.empty();
+                      }
+                    }).subscribeOn(Schedulers.newThread()); // subscribe on a new thread
+                  }
                 });
 
         ConcurrentObserverValidator<String> observer = new ConcurrentObserverValidator<String>();
@@ -474,7 +471,7 @@ public Subscription onSubscribe(final Observer<? super String> observer) {
             fail("Error: " + observer.error.get().getMessage());
         }
     }
-    
+
     @Test
     public void testRecursion() {
         TestScheduler s = new TestScheduler();
@@ -494,11 +491,11 @@ public void call(Action0 self) {
         subscription.unsubscribe();
         assertEquals(0, counter.get());
     }
-    
+
 
     /**
      * Used to determine if onNext is being invoked concurrently.
-     * 
+     *
      * @param <T>
      */
     private static class ConcurrentObserverValidator<T> implements Observer<T> {

rxjava-core/src/test/java/rx/concurrency/CurrentThreadSchedulerTest.java

@@ -0,0 +1,7 @@
+package rx.concurrency;
+
+import org.junit.Ignore;
+
+@Ignore("WIP")
+public class CurrentThreadSchedulerTest {
+}

rxjava-core/src/test/java/rx/concurrency/ImmediateSchedulerTest.java

@@ -0,0 +1,7 @@
+package rx.concurrency;
+
+import org.junit.Ignore;
+
+@Ignore("WIP")
+public class ImmediateSchedulerTest {
+}

rxjava-core/src/test/java/rx/observables/BlockingObservableTest.java

@@ -0,0 +1,7 @@
+package rx.observables;
+
+import org.junit.Ignore;
+
+@Ignore("WIP")
+public class BlockingObservableTest {
+}

rxjava-core/src/test/java/rx/operators/OperationAllTest.java

@@ -0,0 +1,7 @@
+package rx.operators;
+
+import org.junit.Ignore;
+
+@Ignore("WIP")
+public class OperationAllTest {
+}

rxjava-core/src/test/java/rx/operators/OperationAnyTest.java

@@ -0,0 +1,7 @@
+package rx.operators;
+
+import org.junit.Ignore;
+
+@Ignore("WIP")
+public class OperationAnyTest {
+}

rxjava-core/src/test/java/rx/operators/OperationAverageTest.java

@@ -0,0 +1,7 @@
+package rx.operators;
+
+import org.junit.Ignore;
+
+@Ignore("WIP")
+public class OperationAverageTest {
+}

rxjava-core/src/test/java/rx/operators/OperationBufferTest.java

@@ -0,0 +1,7 @@
+package rx.operators;
+
+import org.junit.Ignore;
+
+@Ignore("WIP")
+public class OperationBufferTest {
+}

rxjava-core/src/test/java/rx/operators/OperationCacheTest.java

@@ -0,0 +1,7 @@
+package rx.operators;
+
+import org.junit.Ignore;
+
+@Ignore("WIP")
+public class OperationCacheTest {
+}

rxjava-core/src/test/java/rx/operators/OperationCastTest.java

@@ -0,0 +1,7 @@
+package rx.operators;
+
+import org.junit.Ignore;
+
+@Ignore("WIP")
+public class OperationCastTest {
+}