Added experimental annotations

Author: akarnokd

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

@@ -19,6 +19,7 @@
 import java.util.List;
 
 import rx.Observer;
+import rx.annotations.Experimental;
 import rx.exceptions.CompositeException;
 import rx.exceptions.Exceptions;
 import rx.functions.Action1;
@@ -147,6 +148,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
     public boolean hasValue() {
         Object v = lastValue;
         Object o = state.get();
@@ -156,6 +158,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
     public boolean hasThrowable() {
         Object o = state.get();
         return nl.isError(o);
@@ -164,6 +167,7 @@ public boolean hasThrowable() {
      * Check if the Subject has terminated normally.
      * @return true if the subject completed normally via {@code onCompleted()}
      */
+    @Experimental
     public boolean hasCompleted() {
         Object o = state.get();
         return o != null && !nl.isError(o);
@@ -177,6 +181,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
     public T getValue() {
         Object v = lastValue;
         Object o = state.get();
@@ -190,6 +195,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
     public Throwable getThrowable() {
         Object o = state.get();
         if (nl.isError(o)) {

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

@@ -20,6 +20,7 @@
 import java.util.List;
 
 import rx.Observer;
+import rx.annotations.Experimental;
 import rx.exceptions.CompositeException;
 import rx.exceptions.Exceptions;
 import rx.functions.Action1;
@@ -183,6 +184,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
     public boolean hasValue() {
         Object o = state.get();
         return nl.isNext(o);
@@ -191,6 +193,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
     public boolean hasThrowable() {
         Object o = state.get();
         return nl.isError(o);
@@ -199,6 +202,7 @@ public boolean hasThrowable() {
      * Check if the Subject has terminated normally.
      * @return true if the subject completed normally via {@code onCompleted()}
      */
+    @Experimental
     public boolean hasCompleted() {
         Object o = state.get();
         return nl.isCompleted(o);
@@ -212,6 +216,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
     public T getValue() {
         Object o = state.get();
         if (nl.isNext(o)) {
@@ -224,6 +229,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
     public Throwable getThrowable() {
         Object o = state.get();
         if (nl.isError(o)) {

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

@@ -19,6 +19,7 @@
 import java.util.List;
 
 import rx.Observer;
+import rx.annotations.Experimental;
 import rx.exceptions.CompositeException;
 import rx.exceptions.Exceptions;
 import rx.functions.Action1;
@@ -131,6 +132,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
     public boolean hasThrowable() {
         Object o = state.get();
         return nl.isError(o);
@@ -139,6 +141,7 @@ public boolean hasThrowable() {
      * Check if the Subject has terminated normally.
      * @return true if the subject completed normally via {@code onCompleted}
      */
+    @Experimental
     public boolean hasCompleted() {
         Object o = state.get();
         return o != null && !nl.isError(o);
@@ -148,6 +151,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
     public Throwable getThrowable() {
         Object o = state.get();
         if (nl.isError(o)) {

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

@@ -23,6 +23,7 @@
 
 import rx.Observer;
 import rx.Scheduler;
+import rx.annotations.Experimental;
 import rx.exceptions.CompositeException;
 import rx.exceptions.Exceptions;
 import rx.functions.Action1;
@@ -1061,6 +1062,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
     public boolean hasThrowable() {
         NotificationLite<T> nl = ssm.nl;
         Object o = ssm.get();
@@ -1070,6 +1072,7 @@ public boolean hasThrowable() {
      * Check if the Subject has terminated normally.
      * @return true if the subject completed normally via {@code onCompleted}
      */
+    @Experimental
     public boolean hasCompleted() {
         NotificationLite<T> nl = ssm.nl;
         Object o = ssm.get();
@@ -1080,6 +1083,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
     public Throwable getThrowable() {
         NotificationLite<T> nl = ssm.nl;
         Object o = ssm.get();
@@ -1092,12 +1096,14 @@ public Throwable getThrowable() {
      * Returns the current number of items (non-terminal events) available for replay.
      * @return the number of items available
      */
+    @Experimental
     public int size() {
         return state.size();
     }
     /**
      * @return true if the Subject holds at least one non-terminal event available for replay
      */
+    @Experimental
     public boolean hasAnyValue() {
         return !state.isEmpty();
     }
@@ -1107,6 +1113,7 @@ public boolean hasAnyValue() {
      * @return returns a snapshot of the currently buffered non-terminal events.
      */
     @SuppressWarnings("unchecked")
+    @Experimental
     public Object[] getValues() {
         return state.toArray((T[])EMPTY_ARRAY);
     }
@@ -1116,6 +1123,7 @@ public Object[] getValues() {
      * @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
     public T[] getValues(T[] a) {
         return state.toArray(a);
     }