Skip to content

Commit

Permalink
Marking OnBackpressureBlock as @experimental
Browse files Browse the repository at this point in the history
I chose Experimental instead of Beta since we may still change how it behaves based on what Scheduler is being used.
  • Loading branch information
benjchristensen committed Nov 29, 2014
1 parent f503e44 commit 181c0aa
Showing 1 changed file with 5 additions and 1 deletion.
6 changes: 5 additions & 1 deletion src/main/java/rx/Observable.java
Original file line number Diff line number Diff line change
Expand Up @@ -15,12 +15,12 @@
import java.util.*;
import java.util.concurrent.*;

import rx.annotations.Experimental;
import rx.exceptions.*;
import rx.functions.*;
import rx.internal.operators.*;
import rx.internal.util.ScalarSynchronousObservable;
import rx.internal.util.UtilityFunctions;

import rx.observables.*;
import rx.observers.SafeSubscriber;
import rx.plugins.*;
Expand Down Expand Up @@ -5070,7 +5070,9 @@ public final Observable<T> onBackpressureDrop() {
* @param maxQueueLength the maximum number of items the producer can emit without blocking
* @return the source Observable modified to block {@code onNext} notifications on overflow
* @see <a href="https://github.com/ReactiveX/RxJava/wiki/Backpressure">RxJava wiki: Backpressure</a>
* @Experimental The behavior of this can change at any time.
*/
@Experimental
public final Observable<T> onBackpressureBlock(int maxQueueLength) {
return lift(new OperatorOnBackpressureBlock<T>(maxQueueLength));
}
Expand All @@ -5087,7 +5089,9 @@ public final Observable<T> onBackpressureBlock(int maxQueueLength) {
*
* @return the source Observable modified to block {@code onNext} notifications on overflow
* @see <a href="https://github.com/ReactiveX/RxJava/wiki/Backpressure">RxJava wiki: Backpressure</a>
* @Experimental The behavior of this can change at any time.
*/
@Experimental
public final Observable<T> onBackpressureBlock() {
return onBackpressureBlock(rx.internal.util.RxRingBuffer.SIZE);
}
Expand Down

0 comments on commit 181c0aa

Please sign in to comment.