From 3a9a4e9e4a3463bc93580017654236ed728f65ec Mon Sep 17 00:00:00 2001
From: Ben Christensen <benjchristensen@netflix.com>
Date: Fri, 23 Aug 2013 21:00:24 -0700
Subject: [PATCH] AtomicObservableSubscription to SafeObservableSubscription

---
 .../java/rx/android/concurrency/HandlerThreadScheduler.java   | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

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
index 2a2b165bab..a9cfb55fc9 100644
--- 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