diff --git a/src/main/java/rx/Observable.java b/src/main/java/rx/Observable.java index 74fcf88fe9..b634c92215 100644 --- a/src/main/java/rx/Observable.java +++ b/src/main/java/rx/Observable.java @@ -126,7 +126,7 @@ public static Observable create(OnSubscribe f) { * @see ReactiveX operators documentation: Create * @since (if this graduates from Experimental/Beta to supported, replace this parenthetical with the release number) */ - @Experimental + @Beta public static Observable create(SyncOnSubscribe syncOnSubscribe) { return new Observable(hook.onCreate(syncOnSubscribe)); } diff --git a/src/main/java/rx/observables/SyncOnSubscribe.java b/src/main/java/rx/observables/SyncOnSubscribe.java index 910a5acddb..c2ff69e6e8 100644 --- a/src/main/java/rx/observables/SyncOnSubscribe.java +++ b/src/main/java/rx/observables/SyncOnSubscribe.java @@ -23,6 +23,7 @@ import rx.Producer; import rx.Subscriber; import rx.Subscription; +import rx.annotations.Beta; import rx.annotations.Experimental; import rx.exceptions.Exceptions; import rx.functions.Action0; @@ -46,7 +47,7 @@ * @param * the type of {@code Subscribers} that will be compatible with {@code this}. */ -@Experimental +@Beta public abstract class SyncOnSubscribe implements OnSubscribe { /* (non-Javadoc) @@ -126,7 +127,7 @@ protected void onUnsubscribe(S state) { * next(S, Subscriber)}) * @return a SyncOnSubscribe that emits data in a protocol compatible with back-pressure. */ - @Experimental + @Beta public static SyncOnSubscribe createSingleState(Func0 generator, final Action2> next) { Func2, S> nextFunc = new Func2, S>() { @@ -155,7 +156,7 @@ public S call(S state, Observer subscriber) { * @return a SyncOnSubscribe that emits data downstream in a protocol compatible with * back-pressure. */ - @Experimental + @Beta public static SyncOnSubscribe createSingleState(Func0 generator, final Action2> next, final Action1 onUnsubscribe) { @@ -183,7 +184,7 @@ public S call(S state, Observer subscriber) { * @return a SyncOnSubscribe that emits data downstream in a protocol compatible with * back-pressure. */ - @Experimental + @Beta public static SyncOnSubscribe createStateful(Func0 generator, Func2, ? extends S> next, Action1 onUnsubscribe) { @@ -202,7 +203,7 @@ public static SyncOnSubscribe createStateful(Func0 gen * @return a SyncOnSubscribe that emits data downstream in a protocol compatible with * back-pressure. */ - @Experimental + @Beta public static SyncOnSubscribe createStateful(Func0 generator, Func2, ? extends S> next) { return new SyncOnSubscribeImpl(generator, next); @@ -221,7 +222,7 @@ public static SyncOnSubscribe createStateful(Func0 gen * @return a SyncOnSubscribe that emits data downstream in a protocol compatible with * back-pressure. */ - @Experimental + @Beta public static SyncOnSubscribe createStateless(final Action1> next) { Func2, Void> nextFunc = new Func2, Void>() { @Override @@ -248,7 +249,7 @@ public Void call(Void state, Observer subscriber) { * @return a SyncOnSubscribe that emits data downstream in a protocol compatible with * back-pressure. */ - @Experimental + @Beta public static SyncOnSubscribe createStateless(final Action1> next, final Action0 onUnsubscribe) { Func2, Void> nextFunc = new Func2, Void>() {