Moved sources under main android package.

Excluded the test support package from being included when building a jar or generating javadoc
Javadoc comments added

Author: Mustafa Sezgin

rxjava-contrib/rxjava-android/build.gradle

@@ -32,16 +32,21 @@ idea {
 }
 
 javadoc {
+    exclude "rx/android/testsupport"
+    //Excluding the test support directory causes an error when generating docs
+    failOnError false;
     options {
         doclet = "org.benjchristensen.doclet.DocletExclude"
         docletpath = [rootProject.file('./gradle/doclet-exclude.jar')]
         stylesheetFile = rootProject.file('./gradle/javadocStyleSheet.css')
-        windowTitle = "RxJava Javadoc ${project.version}"
+        windowTitle = "RxJava Android Javadoc ${project.version}"
     }
-    options.addStringOption('top').value = '<h2 class="title" style="padding-top:40px">RxJava</h2>'
+    options.addStringOption('top').value = '<h2 class="title" style="padding-top:40px">RxJava Android</h2>'
 }
 
 jar {
+    exclude "rx/android/testsupport"
+
     manifest {
         name = 'rxjava-android'
         instruction 'Bundle-Vendor', 'Netflix'

rxjava-contrib/rxjava-android/src/main/java/rx/android/concurrency/AndroidSchedulers.java

@@ -0,0 +1,36 @@
+package rx.android.concurrency;
+
+import android.os.Handler;
+import android.os.Looper;
+import rx.Scheduler;
+
+/**
+ * Schedulers that have Android specific functionality
+ */
+public class AndroidSchedulers {
+
+    private static final Scheduler MAIN_THREAD_SCHEDULER =
+            new HandlerThreadScheduler(new Handler(Looper.getMainLooper()));
+
+    private AndroidSchedulers(){
+
+    }
+
+    /**
+     * {@link Scheduler} which uses the provided {@link Handler} to execute an action
+     * @param handler The handler that will be used when executing the action
+     * @return A handler based scheduler
+     */
+    public static Scheduler handlerThread(final Handler handler) {
+        return new HandlerThreadScheduler(handler);
+    }
+
+    /**
+     * {@link Scheduler} which will execute an action on the main Android UI thread.
+     *
+     * @return A Main {@link Looper} based scheduler
+     */
+    public static Scheduler mainThread() {
+        return MAIN_THREAD_SCHEDULER;
+    }
+}

rxjava-contrib/rxjava-android/src/main/java/rx/concurrency/HandlerThreadScheduler.java renamed to rxjava-contrib/rxjava-android/src/main/java/rx/android/concurrency/HandlerThreadScheduler.java

@@ -1,4 +1,4 @@
-package rx.concurrency;
+package rx.android.concurrency;
 
 import android.os.Handler;
 import org.junit.Test;
@@ -23,15 +23,37 @@ public class HandlerThreadScheduler extends Scheduler {
 
     private final Handler handler;
 
+    /**
+     * Constructs a {@link HandlerThreadScheduler} using the given {@link Handler}
+     * @param handler {@link Handler} to use when scheduling actions
+     */
     public HandlerThreadScheduler(Handler handler) {
         this.handler = handler;
     }
 
+    /**
+     * Calls {@link HandlerThreadScheduler#schedule(Object, rx.util.functions.Func2, long, java.util.concurrent.TimeUnit)}
+     * with a delay of zero milliseconds.
+     *
+     * See {@link #schedule(Object, rx.util.functions.Func2, long, java.util.concurrent.TimeUnit)}
+     */
     @Override
     public <T> Subscription schedule(final T state, final Func2<Scheduler, T, Subscription> action) {
         return schedule(state, action, 0L, TimeUnit.MILLISECONDS);
     }
 
+    /**
+     * Calls {@link Handler#postDelayed(Runnable, long)} with a runnable that executes the given action.
+     * @param state
+     *            State to pass into the action.
+     * @param action
+     *            Action to schedule.
+     * @param delayTime
+     *            Time the action is to be delayed before executing.
+     * @param unit
+     *            Time unit of the delay time.
+     * @return A Subscription from which one can unsubscribe from.
+     */
     @Override
     public <T> Subscription schedule(final T state, final Func2<Scheduler, T, Subscription> action, long delayTime, TimeUnit unit) {
         final AtomicObservableSubscription subscription = new AtomicObservableSubscription();