Skip to content

Commit

Permalink
Remove @Beta from FluentFuture.
Browse files Browse the repository at this point in the history
Fixes #3419

RELNOTES=`concurrent`: Remove `@Beta` from `FluentFuture`.
PiperOrigin-RevId: 523466140
  • Loading branch information
kluever authored and Google Java Core Libraries committed Apr 11, 2023
1 parent 15a0c9f commit b9a2d58
Show file tree
Hide file tree
Showing 2 changed files with 0 additions and 13 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -16,7 +16,6 @@

import static com.google.common.base.Preconditions.checkNotNull;

import com.google.common.annotations.Beta;
import com.google.common.annotations.GwtCompatible;
import com.google.common.annotations.GwtIncompatible;
import com.google.common.annotations.J2ktIncompatible;
Expand Down Expand Up @@ -185,7 +184,6 @@ public final boolean cancel(boolean mayInterruptIfRunning) {
*/
@J2ktIncompatible
@Partially.GwtIncompatible("AVAILABLE but requires exceptionType to be Throwable.class")
@Beta
public final <X extends Throwable> FluentFuture<V> catching(
Class<X> exceptionType, Function<? super X, ? extends V> fallback, Executor executor) {
return (FluentFuture<V>) Futures.catching(this, exceptionType, fallback, executor);
Expand Down Expand Up @@ -251,7 +249,6 @@ public final <X extends Throwable> FluentFuture<V> catching(
*/
@J2ktIncompatible
@Partially.GwtIncompatible("AVAILABLE but requires exceptionType to be Throwable.class")
@Beta
public final <X extends Throwable> FluentFuture<V> catchingAsync(
Class<X> exceptionType, AsyncFunction<? super X, ? extends V> fallback, Executor executor) {
return (FluentFuture<V>) Futures.catchingAsync(this, exceptionType, fallback, executor);
Expand All @@ -270,7 +267,6 @@ public final <X extends Throwable> FluentFuture<V> catchingAsync(
@J2ktIncompatible
@GwtIncompatible // ScheduledExecutorService
@SuppressWarnings("GoodTime") // should accept a java.time.Duration
@Beta
public final FluentFuture<V> withTimeout(
long timeout, TimeUnit unit, ScheduledExecutorService scheduledExecutor) {
return (FluentFuture<V>) Futures.withTimeout(this, timeout, unit, scheduledExecutor);
Expand Down Expand Up @@ -315,7 +311,6 @@ public final FluentFuture<V> withTimeout(
* @return A future that holds result of the function (if the input succeeded) or the original
* input's failure (if not)
*/
@Beta
public final <T extends @Nullable Object> FluentFuture<T> transformAsync(
AsyncFunction<? super V, T> function, Executor executor) {
return (FluentFuture<T>) Futures.transformAsync(this, function, executor);
Expand Down Expand Up @@ -353,7 +348,6 @@ public final FluentFuture<V> withTimeout(
* @param executor Executor to run the function in.
* @return A future that holds result of the transformation.
*/
@Beta
public final <T extends @Nullable Object> FluentFuture<T> transform(
Function<? super V, T> function, Executor executor) {
return (FluentFuture<T>) Futures.transform(this, function, executor);
Expand Down
7 changes: 0 additions & 7 deletions guava/src/com/google/common/util/concurrent/FluentFuture.java
Original file line number Diff line number Diff line change
Expand Up @@ -17,7 +17,6 @@
import static com.google.common.base.Preconditions.checkNotNull;
import static com.google.common.util.concurrent.Internal.toNanosSaturated;

import com.google.common.annotations.Beta;
import com.google.common.annotations.GwtCompatible;
import com.google.common.annotations.GwtIncompatible;
import com.google.common.annotations.J2ktIncompatible;
Expand Down Expand Up @@ -187,7 +186,6 @@ public final boolean cancel(boolean mayInterruptIfRunning) {
*/
@J2ktIncompatible
@Partially.GwtIncompatible("AVAILABLE but requires exceptionType to be Throwable.class")
@Beta
public final <X extends Throwable> FluentFuture<V> catching(
Class<X> exceptionType, Function<? super X, ? extends V> fallback, Executor executor) {
return (FluentFuture<V>) Futures.catching(this, exceptionType, fallback, executor);
Expand Down Expand Up @@ -253,7 +251,6 @@ public final <X extends Throwable> FluentFuture<V> catching(
*/
@J2ktIncompatible
@Partially.GwtIncompatible("AVAILABLE but requires exceptionType to be Throwable.class")
@Beta
public final <X extends Throwable> FluentFuture<V> catchingAsync(
Class<X> exceptionType, AsyncFunction<? super X, ? extends V> fallback, Executor executor) {
return (FluentFuture<V>) Futures.catchingAsync(this, exceptionType, fallback, executor);
Expand All @@ -271,7 +268,6 @@ public final <X extends Throwable> FluentFuture<V> catchingAsync(
*/
@J2ktIncompatible
@GwtIncompatible // ScheduledExecutorService
@Beta
public final FluentFuture<V> withTimeout(
Duration timeout, ScheduledExecutorService scheduledExecutor) {
return withTimeout(toNanosSaturated(timeout), TimeUnit.NANOSECONDS, scheduledExecutor);
Expand All @@ -290,7 +286,6 @@ public final FluentFuture<V> withTimeout(
@J2ktIncompatible
@GwtIncompatible // ScheduledExecutorService
@SuppressWarnings("GoodTime") // should accept a java.time.Duration
@Beta
public final FluentFuture<V> withTimeout(
long timeout, TimeUnit unit, ScheduledExecutorService scheduledExecutor) {
return (FluentFuture<V>) Futures.withTimeout(this, timeout, unit, scheduledExecutor);
Expand Down Expand Up @@ -335,7 +330,6 @@ public final FluentFuture<V> withTimeout(
* @return A future that holds result of the function (if the input succeeded) or the original
* input's failure (if not)
*/
@Beta
public final <T extends @Nullable Object> FluentFuture<T> transformAsync(
AsyncFunction<? super V, T> function, Executor executor) {
return (FluentFuture<T>) Futures.transformAsync(this, function, executor);
Expand Down Expand Up @@ -373,7 +367,6 @@ public final FluentFuture<V> withTimeout(
* @param executor Executor to run the function in.
* @return A future that holds result of the transformation.
*/
@Beta
public final <T extends @Nullable Object> FluentFuture<T> transform(
Function<? super V, T> function, Executor executor) {
return (FluentFuture<T>) Futures.transform(this, function, executor);
Expand Down

0 comments on commit b9a2d58

Please sign in to comment.