use volatile boolean instead of AtomicBoolean

Author: davidmoten

src/main/java/rx/internal/operators/OperatorSkipTimed.java

@@ -16,11 +16,11 @@
 package rx.internal.operators;
 
 import java.util.concurrent.TimeUnit;
-import java.util.concurrent.atomic.AtomicBoolean;
 
-import rx.*;
 import rx.Observable.Operator;
+import rx.Scheduler;
 import rx.Scheduler.Worker;
+import rx.Subscriber;
 import rx.functions.Action0;
 
 /**
@@ -42,44 +42,48 @@ public OperatorSkipTimed(long time, TimeUnit unit, Scheduler scheduler) {
     public Subscriber<? super T> call(final Subscriber<? super T> child) {
         final Worker worker = scheduler.createWorker();
         child.add(worker);
-        final AtomicBooleanAction gate = new AtomicBooleanAction();
-        worker.schedule(gate, time, unit);
-        return new Subscriber<T>(child) {
+        SkipTimedSubscriber<T> subscriber = new SkipTimedSubscriber<T>(child);
+        worker.schedule(subscriber, time, unit);
+        return subscriber;
+    }
+    
+    final static class SkipTimedSubscriber<T> extends Subscriber<T> implements Action0 {
 
-            @Override
-            public void onNext(T t) {
-                if (gate.get()) {
-                    child.onNext(t);
-                }
-            }
+        Subscriber<? super T> child;
+        volatile boolean gate;
 
-            @Override
-            public void onError(Throwable e) {
-                try {
-                    child.onError(e);
-                } finally {
-                    unsubscribe();
-                }
-            }
+        SkipTimedSubscriber(Subscriber<? super T> child) {
+            this.child = child;
+        }
 
-            @Override
-            public void onCompleted() {
-                try {
-                    child.onCompleted();
-                } finally {
-                    unsubscribe();
-                }
+        @Override
+        public void call() {
+            gate = true;
+        }
+        
+        @Override
+        public void onNext(T t) {
+            if (gate) {
+                child.onNext(t);
             }
-        };
-    }
-    
-    final static class AtomicBooleanAction extends AtomicBoolean implements Action0 {
+        }
 
-        private static final long serialVersionUID = 8308944559386967982L;
+        @Override
+        public void onError(Throwable e) {
+            try {
+                child.onError(e);
+            } finally {
+                unsubscribe();
+            }
+        }
 
         @Override
-        public void call() {
-            set(true);
+        public void onCompleted() {
+            try {
+                child.onCompleted();
+            } finally {
+                unsubscribe();
+            }
         }
 
     }