1.0.15. Beta/Deprecation of Subject state peeking methods.

This should give users one release to prepare for the class structure
changes.

Author: akarnokd

src/main/java/rx/subjects/AsyncSubject.java

@@ -19,7 +19,7 @@
 import java.util.*;
 
 import rx.Observer;
-import rx.annotations.Experimental;
+import rx.annotations.Beta;
 import rx.exceptions.Exceptions;
 import rx.functions.Action1;
 import rx.internal.operators.NotificationLite;
@@ -141,7 +141,7 @@ public boolean hasObservers() {
      * retrieved by {@code getValue()} may get outdated.
      * @return true if and only if the subject has some value but not an error
      */
-    @Experimental
+    @Beta
     @Override
     public boolean hasValue() {
         Object v = lastValue;
@@ -152,7 +152,7 @@ public boolean hasValue() {
      * Check if the Subject has terminated with an exception.
      * @return true if the subject has received a throwable through {@code onError}.
      */
-    @Experimental
+    @Beta
     @Override
     public boolean hasThrowable() {
         Object o = state.get();
@@ -162,7 +162,7 @@ public boolean hasThrowable() {
      * Check if the Subject has terminated normally.
      * @return true if the subject completed normally via {@code onCompleted()}
      */
-    @Experimental
+    @Beta
     @Override
     public boolean hasCompleted() {
         Object o = state.get();
@@ -177,7 +177,7 @@ public boolean hasCompleted() {
      * @return the current value or {@code null} if the Subject doesn't have a value,
      * has terminated with an exception or has an actual {@code null} as a value.
      */
-    @Experimental
+    @Beta
     @Override
     public T getValue() {
         Object v = lastValue;
@@ -192,7 +192,7 @@ public T getValue() {
      * @return the Throwable that terminated the Subject or {@code null} if the
      * subject hasn't terminated yet or it terminated normally.
      */
-    @Experimental
+    @Beta
     @Override
     public Throwable getThrowable() {
         Object o = state.get();
@@ -202,7 +202,7 @@ public Throwable getThrowable() {
         return null;
     }
     @Override
-    @Experimental
+    @Deprecated
     @SuppressWarnings("unchecked")
     public T[] getValues(T[] a) {
         Object v = lastValue;

src/main/java/rx/subjects/BehaviorSubject.java

@@ -20,7 +20,7 @@
 import java.util.*;
 
 import rx.Observer;
-import rx.annotations.Experimental;
+import rx.annotations.Beta;
 import rx.exceptions.Exceptions;
 import rx.functions.Action1;
 import rx.internal.operators.NotificationLite;
@@ -177,7 +177,7 @@ public boolean hasObservers() {
      * retrieved by {@code getValue()} may get outdated.
      * @return true if and only if the subject has some value and hasn't terminated yet.
      */
-    @Experimental
+    @Beta
     @Override
     public boolean hasValue() {
         Object o = state.get();
@@ -187,7 +187,7 @@ public boolean hasValue() {
      * Check if the Subject has terminated with an exception.
      * @return true if the subject has received a throwable through {@code onError}.
      */
-    @Experimental
+    @Beta
     @Override
     public boolean hasThrowable() {
         Object o = state.get();
@@ -197,7 +197,7 @@ public boolean hasThrowable() {
      * Check if the Subject has terminated normally.
      * @return true if the subject completed normally via {@code onCompleted()}
      */
-    @Experimental
+    @Beta
     @Override
     public boolean hasCompleted() {
         Object o = state.get();
@@ -212,7 +212,7 @@ public boolean hasCompleted() {
      * @return the current value or {@code null} if the Subject doesn't have a value,
      * has terminated or has an actual {@code null} as a valid value.
      */
-    @Experimental
+    @Beta
     @Override
     public T getValue() {
         Object o = state.get();
@@ -226,7 +226,7 @@ public T getValue() {
      * @return the Throwable that terminated the Subject or {@code null} if the
      * subject hasn't terminated yet or it terminated normally.
      */
-    @Experimental
+    @Beta
     @Override
     public Throwable getThrowable() {
         Object o = state.get();
@@ -236,7 +236,7 @@ public Throwable getThrowable() {
         return null;
     }
     @Override
-    @Experimental
+    @Beta
     @SuppressWarnings("unchecked")
     public T[] getValues(T[] a) {
         Object o = state.get();

src/main/java/rx/subjects/PublishSubject.java

@@ -18,7 +18,7 @@
 import java.util.*;
 
 import rx.Observer;
-import rx.annotations.Experimental;
+import rx.annotations.Beta;
 import rx.exceptions.Exceptions;
 import rx.functions.Action1;
 import rx.internal.operators.NotificationLite;
@@ -124,7 +124,7 @@ public boolean hasObservers() {
      * Check if the Subject has terminated with an exception.
      * @return true if the subject has received a throwable through {@code onError}.
      */
-    @Experimental
+    @Beta
     @Override
     public boolean hasThrowable() {
         Object o = state.get();
@@ -134,7 +134,7 @@ public boolean hasThrowable() {
      * Check if the Subject has terminated normally.
      * @return true if the subject completed normally via {@code onCompleted}
      */
-    @Experimental
+    @Beta
     @Override
     public boolean hasCompleted() {
         Object o = state.get();
@@ -145,7 +145,7 @@ public boolean hasCompleted() {
      * @return the Throwable that terminated the Subject or {@code null} if the
      * subject hasn't terminated yet or it terminated normally.
      */
-    @Experimental
+    @Beta
     @Override
     public Throwable getThrowable() {
         Object o = state.get();
@@ -155,23 +155,40 @@ public Throwable getThrowable() {
         return null;
     }
 
+    /**
+     * {@inheritDoc}
+     * @deprecated this method is scheduled to be removed in the next release
+     */
     @Override
-    @Experimental
+    @Deprecated
     public boolean hasValue() {
         return false;
     }
+
+    /**
+     * {@inheritDoc}
+     * @deprecated this method is scheduled to be removed in the next release
+     */
     @Override
-    @Experimental
+    @Deprecated
     public T getValue() {
         return null;
     }
+    /**
+     * {@inheritDoc}
+     * @deprecated this method is scheduled to be removed in the next release
+     */
     @Override
-    @Experimental
+    @Deprecated
     public Object[] getValues() {
         return new Object[0];
     }
+    /**
+     * {@inheritDoc}
+     * @deprecated this method is scheduled to be removed in the next release
+     */
     @Override
-    @Experimental
+    @Deprecated
     public T[] getValues(T[] a) {
         if (a.length > 0) {
             a[0] = null;

src/main/java/rx/subjects/ReplaySubject.java

@@ -20,9 +20,9 @@
 import java.util.concurrent.TimeUnit;
 import java.util.concurrent.atomic.AtomicIntegerFieldUpdater;
 
-import rx.*;
 import rx.Observer;
-import rx.annotations.Experimental;
+import rx.Scheduler;
+import rx.annotations.Beta;
 import rx.exceptions.Exceptions;
 import rx.functions.*;
 import rx.internal.operators.NotificationLite;
@@ -1098,7 +1098,7 @@ public void evictFinal(NodeList<Object> list) {
      * Check if the Subject has terminated with an exception.
      * @return true if the subject has received a throwable through {@code onError}.
      */
-    @Experimental
+    @Beta
     @Override
     public boolean hasThrowable() {
         NotificationLite<T> nl = ssm.nl;
@@ -1109,7 +1109,7 @@ public boolean hasThrowable() {
      * Check if the Subject has terminated normally.
      * @return true if the subject completed normally via {@code onCompleted}
      */
-    @Experimental
+    @Beta
     @Override
     public boolean hasCompleted() {
         NotificationLite<T> nl = ssm.nl;
@@ -1121,7 +1121,7 @@ public boolean hasCompleted() {
      * @return the Throwable that terminated the Subject or {@code null} if the
      * subject hasn't terminated yet or it terminated normally.
      */
-    @Experimental
+    @Beta
     @Override
     public Throwable getThrowable() {
         NotificationLite<T> nl = ssm.nl;
@@ -1135,18 +1135,18 @@ public Throwable getThrowable() {
      * Returns the current number of items (non-terminal events) available for replay.
      * @return the number of items available
      */
-    @Experimental
+    @Beta
     public int size() {
         return state.size();
     }
     /**
      * @return true if the Subject holds at least one non-terminal event available for replay
      */
-    @Experimental
+    @Beta
     public boolean hasAnyValue() {
         return !state.isEmpty();
     }
-    @Experimental
+    @Beta
     @Override
     public boolean hasValue() {
         return hasAnyValue();
@@ -1157,12 +1157,14 @@ public boolean hasValue() {
      * @param a the array to fill in
      * @return the array {@code a} if it had enough capacity or a new array containing the available values 
      */
-    @Experimental
+    @Beta
     @Override
     public T[] getValues(T[] a) {
         return state.toArray(a);
     }
+    
     @Override
+    @Beta
     public T getValue() {
         return state.latest();
     }

src/main/java/rx/subjects/SerializedSubject.java

@@ -16,7 +16,6 @@
 package rx.subjects;
 
 import rx.Subscriber;
-import rx.annotations.Experimental;
 import rx.observers.SerializedObserver;
 
 /**
@@ -69,38 +68,67 @@ public void onNext(T t) {
     public boolean hasObservers() {
         return actual.hasObservers();
     }
+    
+    /**
+     * {@inheritDoc}
+     * @deprecated this method is scheduled to be removed in the next release
+     */
     @Override
-    @Experimental
+    @Deprecated
     public boolean hasCompleted() {
         return actual.hasCompleted();
     }
+    /**
+     * {@inheritDoc}
+     * @deprecated this method is scheduled to be removed in the next release
+     */
     @Override
-    @Experimental
+    @Deprecated
     public boolean hasThrowable() {
         return actual.hasThrowable();
     }
+    /**
+     * {@inheritDoc}
+     * @deprecated this method is scheduled to be removed in the next release
+     */
     @Override
-    @Experimental
+    @Deprecated
     public boolean hasValue() {
         return actual.hasValue();
     }
+    /**
+     * {@inheritDoc}
+     * @deprecated this method is scheduled to be removed in the next release
+     */
     @Override
-    @Experimental
+    @Deprecated
     public Throwable getThrowable() {
         return actual.getThrowable();
     }
+    /**
+     * {@inheritDoc}
+     * @deprecated this method is scheduled to be removed in the next release
+     */
     @Override
-    @Experimental
+    @Deprecated
     public T getValue() {
         return actual.getValue();
     }
+    /**
+     * {@inheritDoc}
+     * @deprecated this method is scheduled to be removed in the next release
+     */
     @Override
-    @Experimental
+    @Deprecated
     public Object[] getValues() {
         return actual.getValues();
     }
+    /**
+     * {@inheritDoc}
+     * @deprecated this method is scheduled to be removed in the next release
+     */
     @Override
-    @Experimental
+    @Deprecated
     public T[] getValues(T[] a) {
         return actual.getValues(a);
     }