change Atomic*FieldUpdater to Atomic* because of ReactiveX/RxJava#3488

Author: davidmoten

pom.xml

@@ -20,7 +20,7 @@
         <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
         <project.reporting.outputEncoding>UTF-8</project.reporting.outputEncoding>
         <maven.compiler.target>1.6</maven.compiler.target>
-        <rxjava.version>1.0.15</rxjava.version>
+        <rxjava.version>1.0.14</rxjava.version>
         <jmh.version>1.11.1</jmh.version>
         <exec.version>1.4.0</exec.version>
         <slf4j.version>1.7.12</slf4j.version>

src/main/java/com/github/davidmoten/rx/subjects/PublishSubjectSingleSubscriber.java

@@ -1,6 +1,6 @@
 package com.github.davidmoten.rx.subjects;
 
-import java.util.concurrent.atomic.AtomicReferenceFieldUpdater;
+import java.util.concurrent.atomic.AtomicReference;
 
 import rx.Subscriber;
 import rx.subjects.Subject;
@@ -42,44 +42,38 @@ public static <T> PublishSubjectSingleSubscriber<T> create() {
 
     @Override
     public void onCompleted() {
-        if (subscriberHolder.subscriber != null) {
-            subscriberHolder.subscriber.onCompleted();
+        if (subscriberHolder.subscriber.get() != null) {
+            subscriberHolder.subscriber.get().onCompleted();
         }
     }
 
     @Override
     public void onError(Throwable e) {
-        if (subscriberHolder.subscriber != null)
-            subscriberHolder.subscriber.onError(e);
+        if (subscriberHolder.subscriber.get() != null)
+            subscriberHolder.subscriber.get().onError(e);
     }
 
     @Override
     public void onNext(T t) {
-        if (subscriberHolder.subscriber != null)
-            subscriberHolder.subscriber.onNext(t);
+        if (subscriberHolder.subscriber.get() != null)
+            subscriberHolder.subscriber.get().onNext(t);
     }
 
     private static class SingleSubscribeOnSubscribe<T> implements OnSubscribe<T> {
 
-        volatile Subscriber<? super T> subscriber;
-
-        @SuppressWarnings("rawtypes")
-        private final AtomicReferenceFieldUpdater<SingleSubscribeOnSubscribe, Subscriber> SUBSCRIBER = AtomicReferenceFieldUpdater
-                .newUpdater(SingleSubscribeOnSubscribe.class, Subscriber.class, "subscriber");
+        final AtomicReference<Subscriber<? super T>> subscriber = new AtomicReference<Subscriber<? super T>>();
 
         @Override
-        public void call(Subscriber<? super T> subscriber) {
-            if (SUBSCRIBER.compareAndSet(this, null, subscriber))
-                this.subscriber = subscriber;
-            else
+        public void call(Subscriber<? super T> sub) {
+            if (!subscriber.compareAndSet(null, sub))
                 throw new RuntimeException(ONLY_ONE_SUBSCRIPTION_IS_ALLOWED);
         }
 
     }
 
     @Override
     public boolean hasObservers() {
-        return subscriberHolder.subscriber != null;
+        return subscriberHolder.subscriber.get() != null;
     }
 
 }