From 8758fdd98cca2ed065654bb5a93a0351327aeda0 Mon Sep 17 00:00:00 2001 From: Ben Christensen Date: Wed, 4 Mar 2015 13:57:09 -0800 Subject: [PATCH] Add Experimental to onBackpressureDrop(Action1) --- src/main/java/rx/Observable.java | 3 +++ 1 file changed, 3 insertions(+) diff --git a/src/main/java/rx/Observable.java b/src/main/java/rx/Observable.java index 01e14e0e12..b65fd94f5b 100644 --- a/src/main/java/rx/Observable.java +++ b/src/main/java/rx/Observable.java @@ -5279,7 +5279,10 @@ public final Observable onBackpressureBuffer(long capacity, Action0 onOverflo * @param onDrop the action to invoke for each item dropped. onDrop action should be fast and should never block. * @return the source Observable modified to drop {@code onNext} notifications on overflow * @see ReactiveX operators documentation: backpressure operators + * @Experimental The behavior of this can change at any time. + * @since (if this graduates from Experimental/Beta to supported, replace this parenthetical with the release number) */ + @Experimental public final Observable onBackpressureDrop(Action1 onDrop) { return lift(new OperatorOnBackpressureDrop(onDrop)); }