File tree Expand file tree Collapse file tree 1 file changed +6
-1
lines changed Expand file tree Collapse file tree 1 file changed +6
-1
lines changed Original file line number Diff line number Diff line change 1515import java .util .*;
1616import java .util .concurrent .*;
1717
18+ import rx .annotations .Beta ;
1819import rx .annotations .Experimental ;
1920import rx .exceptions .*;
2021import rx .functions .*;
@@ -5049,7 +5050,9 @@ public final Observable<T> onBackpressureBuffer() {
50495050 *
50505051 * @return the source Observable modified to buffer items up to the given capacity.
50515052 * @see <a href="https://github.com/ReactiveX/RxJava/wiki/Backpressure">RxJava wiki: Backpressure</a>
5053+ * @Beta
50525054 */
5055+ @ Beta
50535056 public final Observable <T > onBackpressureBuffer (long capacity ) {
50545057 return lift (new OperatorOnBackpressureBuffer <T >(capacity ));
50555058 }
@@ -5068,8 +5071,10 @@ public final Observable<T> onBackpressureBuffer(long capacity) {
50685071 *
50695072 * @return the source Observable modified to buffer items up to the given capacity.
50705073 * @see <a href="https://github.com/ReactiveX/RxJava/wiki/Backpressure">RxJava wiki: Backpressure</a>
5074+ * @Beta
50715075 */
5072- public final Observable <T > onBackpressureBuffer (long capacity , Func0 <Void > onOverflow ) {
5076+ @ Beta
5077+ public final Observable <T > onBackpressureBuffer (long capacity , Action0 onOverflow ) {
50735078 return lift (new OperatorOnBackpressureBuffer <T >(capacity , onOverflow ));
50745079 }
50755080
You can’t perform that action at this time.
0 commit comments