Initial support for scheduling on Android Handler threads

rxjava-contrib/rxjava-android/build.gradle

@@ -0,0 +1,51 @@
+apply plugin: 'java'
+apply plugin: 'eclipse'
+apply plugin: 'idea'
+apply plugin: 'osgi'
+
+sourceCompatibility = JavaVersion.VERSION_1_6
+targetCompatibility = JavaVersion.VERSION_1_6
+
+dependencies {
+    compile project(':rxjava-core')
+    provided 'junit:junit-dep:4.10'
+    provided 'org.mockito:mockito-core:1.8.5'
+    provided 'com.pivotallabs:robolectric:1.2'
+    provided 'com.google.android:android:4.0.1.2'
+}
+
+eclipse {
+  classpath {
+    // include 'provided' dependencies on the classpath
+    plusConfigurations += configurations.provided
+
+    downloadSources = true
+    downloadJavadoc = true
+  }
+}
+
+idea {
+	module {
+		// include 'provided' dependencies on the classpath
+		scopes.PROVIDED.plus += configurations.provided
+	}
+}
+
+javadoc {
+    options {
+        doclet = "org.benjchristensen.doclet.DocletExclude"
+        docletpath = [rootProject.file('./gradle/doclet-exclude.jar')]
+        stylesheetFile = rootProject.file('./gradle/javadocStyleSheet.css')
+        windowTitle = "RxJava Javadoc ${project.version}"
+    }
+    options.addStringOption('top').value = '<h2 class="title" style="padding-top:40px">RxJava</h2>'
+}
+
+jar {
+    manifest {
+        name = 'rxjava-android'
+        instruction 'Bundle-Vendor', 'Netflix'
+        instruction 'Bundle-DocURL', 'https://github.com/Netflix/RxJava'
+        instruction 'Import-Package', '!org.junit,!junit.framework,!org.mockito.*,*'
+    }
+}

rxjava-contrib/rxjava-android/src/main/java/rx/android/testsupport/AndroidTestRunner.java

@@ -0,0 +1,14 @@
+package rx.android.testsupport;
+
+import com.xtremelabs.robolectric.RobolectricConfig;
+import com.xtremelabs.robolectric.RobolectricTestRunner;
+import org.junit.runners.model.InitializationError;
+
+import java.io.File;
+
+public class AndroidTestRunner extends RobolectricTestRunner {
+
+    public AndroidTestRunner(Class<?> testClass) throws InitializationError {
+        super(testClass, new RobolectricConfig(new File("src/test/resources")));
+    }
+}

rxjava-contrib/rxjava-android/src/main/java/rx/android/testsupport/R.java

@@ -0,0 +1,5 @@
+package rx.android.testsupport;
+
+public class R {
+    // resource stub for Robolectric
+}

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

@@ -0,0 +1,19 @@
+package rx.concurrency;
+
+import android.os.Handler;
+import android.os.Looper;
+import rx.Scheduler;
+
+public class AndroidSchedulers {
+
+    private static final Scheduler MAIN_THREAD_SCHEDULER =
+            new HandlerThreadScheduler(new Handler(Looper.getMainLooper()));
+
+    public static Scheduler handlerThread(final Handler handler) {
+        return new HandlerThreadScheduler(handler);
+    }
+
+    public static Scheduler mainThread() {
+        return MAIN_THREAD_SCHEDULER;
+    }
+}

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

@@ -0,0 +1,89 @@
+package rx.concurrency;
+
+import android.os.Handler;
+import org.junit.Test;
+import org.junit.runner.RunWith;
+import org.mockito.ArgumentCaptor;
+import rx.Scheduler;
+import rx.Subscription;
+import rx.android.testsupport.AndroidTestRunner;
+import rx.operators.AtomicObservableSubscription;
+import rx.util.functions.Func2;
+
+import java.util.concurrent.TimeUnit;
+
+import static org.mockito.Matchers.eq;
+import static org.mockito.Mockito.mock;
+import static org.mockito.Mockito.verify;
+
+/**
+ * Schedules actions to run on an Android Handler thread.
+ */
+public class HandlerThreadScheduler extends Scheduler {
+
+    private final Handler handler;
+
+    public HandlerThreadScheduler(Handler handler) {
+        this.handler = handler;
+    }
+
+    @Override
+    public <T> Subscription schedule(final T state, final Func2<Scheduler, T, Subscription> action) {
+        return schedule(state, action, 0L, TimeUnit.MILLISECONDS);
+    }
+
+    @Override
+    public <T> Subscription schedule(final T state, final Func2<Scheduler, T, Subscription> action, long delayTime, TimeUnit unit) {
+        final AtomicObservableSubscription subscription = new AtomicObservableSubscription();
+        final Scheduler _scheduler = this;
+        handler.postDelayed(new Runnable() {
+            @Override
+            public void run() {
+                subscription.wrap(action.call(_scheduler, state));
+            }
+        }, unit.toMillis(delayTime));
+        return subscription;
+    }
+
+    @RunWith(AndroidTestRunner.class)
+    public static final class UnitTest {
+
+        @Test
+        public void shouldScheduleImmediateActionOnHandlerThread() {
+            final Handler handler = mock(Handler.class);
+            final Object state = new Object();
+            final Func2<Scheduler, Object, Subscription> action = mock(Func2.class);
+
+            Scheduler scheduler = new HandlerThreadScheduler(handler);
+            scheduler.schedule(state, action);
+
+            // verify that we post to the given Handler
+            ArgumentCaptor<Runnable> runnable = ArgumentCaptor.forClass(Runnable.class);
+            verify(handler).postDelayed(runnable.capture(), eq(0L));
+
+            // verify that the given handler delegates to our action
+            runnable.getValue().run();
+            verify(action).call(scheduler, state);
+        }
+
+        @Test
+        public void shouldScheduleDelayedActionOnHandlerThread() {
+            final Handler handler = mock(Handler.class);
+            final Object state = new Object();
+            final Func2<Scheduler, Object, Subscription> action = mock(Func2.class);
+
+            Scheduler scheduler = new HandlerThreadScheduler(handler);
+            scheduler.schedule(state, action, 1L, TimeUnit.SECONDS);
+
+            // verify that we post to the given Handler
+            ArgumentCaptor<Runnable> runnable = ArgumentCaptor.forClass(Runnable.class);
+            verify(handler).postDelayed(runnable.capture(), eq(1000L));
+
+            // verify that the given handler delegates to our action
+            runnable.getValue().run();
+            verify(action).call(scheduler, state);
+        }
+    }
+}
+
+

rxjava-contrib/rxjava-android/src/test/resources/AndroidManifest.xml

@@ -0,0 +1,6 @@
+<?xml version="1.0" encoding="utf-8"?>
+<manifest package="rx.android.testsupport">
+
+    <application />
+
+</manifest>

settings.gradle

@@ -4,4 +4,5 @@ include 'rxjava-core', \
 'language-adaptors:rxjava-jruby', \
 'language-adaptors:rxjava-clojure', \
 'language-adaptors:rxjava-scala', \
-'rxjava-contrib:rxjava-swing'
+'rxjava-contrib:rxjava-swing', \
+'rxjava-contrib:rxjava-android'