File tree Expand file tree Collapse file tree 1 file changed +5
-1
lines changed Expand file tree Collapse file tree 1 file changed +5
-1
lines changed Original file line number Diff line number Diff line change 15
15
import java .util .*;
16
16
import java .util .concurrent .*;
17
17
18
+ import rx .annotations .Experimental ;
18
19
import rx .exceptions .*;
19
20
import rx .functions .*;
20
21
import rx .internal .operators .*;
21
22
import rx .internal .util .ScalarSynchronousObservable ;
22
23
import rx .internal .util .UtilityFunctions ;
23
-
24
24
import rx .observables .*;
25
25
import rx .observers .SafeSubscriber ;
26
26
import rx .plugins .*;
@@ -5070,7 +5070,9 @@ public final Observable<T> onBackpressureDrop() {
5070
5070
* @param maxQueueLength the maximum number of items the producer can emit without blocking
5071
5071
* @return the source Observable modified to block {@code onNext} notifications on overflow
5072
5072
* @see <a href="https://github.com/ReactiveX/RxJava/wiki/Backpressure">RxJava wiki: Backpressure</a>
5073
+ * @Experimental The behavior of this can change at any time.
5073
5074
*/
5075
+ @ Experimental
5074
5076
public final Observable <T > onBackpressureBlock (int maxQueueLength ) {
5075
5077
return lift (new OperatorOnBackpressureBlock <T >(maxQueueLength ));
5076
5078
}
@@ -5087,7 +5089,9 @@ public final Observable<T> onBackpressureBlock(int maxQueueLength) {
5087
5089
*
5088
5090
* @return the source Observable modified to block {@code onNext} notifications on overflow
5089
5091
* @see <a href="https://github.com/ReactiveX/RxJava/wiki/Backpressure">RxJava wiki: Backpressure</a>
5092
+ * @Experimental The behavior of this can change at any time.
5090
5093
*/
5094
+ @ Experimental
5091
5095
public final Observable <T > onBackpressureBlock () {
5092
5096
return onBackpressureBlock (rx .internal .util .RxRingBuffer .SIZE );
5093
5097
}
You can’t perform that action at this time.
0 commit comments