AtomicObservableSubscription to SafeObservableSubscription

benjchristensen · benjchristensen · commit 3a9a4e9e4a34 · 2013-08-23T21:00:24.000-07:00
diff --git a/rxjava-contrib/rxjava-android/src/main/java/rx/android/concurrency/HandlerThreadScheduler.java b/rxjava-contrib/rxjava-android/src/main/java/rx/android/concurrency/HandlerThreadScheduler.java
@@ -8,7 +8,7 @@
 import org.robolectric.annotation.Config;
 import rx.Scheduler;
 import rx.Subscription;
-import rx.operators.AtomicObservableSubscription;
+import rx.operators.SafeObservableSubscription;
 import rx.util.functions.Func2;
 
 import java.util.concurrent.TimeUnit;
@@ -57,7 +57,7 @@ public <T> Subscription schedule(final T state, final Func2<Scheduler, T, Subscr
      */
     @Override
     public <T> Subscription schedule(final T state, final Func2<Scheduler, T, Subscription> action, long delayTime, TimeUnit unit) {
-        final AtomicObservableSubscription subscription = new AtomicObservableSubscription();
+        final SafeObservableSubscription subscription = new SafeObservableSubscription();
         final Scheduler _scheduler = this;
         handler.postDelayed(new Runnable() {
             @Override
