- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 11 for TrustedFuture (0.08 sec)
-
guava-gwt/src-super/com/google/common/util/concurrent/super/com/google/common/util/concurrent/AbstractFuture.java
* any of the public methods of ListenableFuture. */ interface Trusted<V extends @Nullable Object> extends ListenableFuture<V> {} abstract static class TrustedFuture<V extends @Nullable Object> extends AbstractFuture<V> implements Trusted<V> { @CanIgnoreReturnValue @Override public final V get() throws InterruptedException, ExecutionException {
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Mon Jan 22 19:37:41 UTC 2024 - 12.3K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/AggregateFutureState.java
*/ @GwtCompatible(emulated = true) @ReflectionSupport(value = ReflectionSupport.Level.FULL) @ElementTypesAreNonnullByDefault abstract class AggregateFutureState<OutputT extends @Nullable Object> extends AbstractFuture.TrustedFuture<OutputT> { // Lazily initialized the first time we see an exception; not released until all the input futures // have completed and we have processed them all.
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Tue May 28 20:40:51 UTC 2024 - 8.4K bytes - Viewed (0) -
guava/src/com/google/common/util/concurrent/AbstractTransformFuture.java
}) abstract class AbstractTransformFuture< I extends @Nullable Object, O extends @Nullable Object, F, T extends @Nullable Object> extends FluentFuture.TrustedFuture<O> implements Runnable { static <I extends @Nullable Object, O extends @Nullable Object> ListenableFuture<O> createAsync( ListenableFuture<I> input, AsyncFunction<? super I, ? extends O> function,
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Fri Oct 25 13:13:32 UTC 2024 - 11K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/AbstractCatchingFuture.java
}) abstract class AbstractCatchingFuture< V extends @Nullable Object, X extends Throwable, F, T extends @Nullable Object> extends FluentFuture.TrustedFuture<V> implements Runnable { static <V extends @Nullable Object, X extends Throwable> ListenableFuture<V> create( ListenableFuture<? extends V> input, Class<X> exceptionType,
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Fri Oct 25 13:13:32 UTC 2024 - 9.1K bytes - Viewed (0) -
guava/src/com/google/common/util/concurrent/AggregateFutureState.java
*/ @GwtCompatible(emulated = true) @ReflectionSupport(value = ReflectionSupport.Level.FULL) @ElementTypesAreNonnullByDefault abstract class AggregateFutureState<OutputT extends @Nullable Object> extends AbstractFuture.TrustedFuture<OutputT> { // Lazily initialized the first time we see an exception; not released until all the input futures // have completed and we have processed them all.
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Tue May 28 20:40:51 UTC 2024 - 8.4K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/TimeoutFuture.java
* interrupted and cancelled if it times out. */ @J2ktIncompatible @GwtIncompatible @ElementTypesAreNonnullByDefault final class TimeoutFuture<V extends @Nullable Object> extends FluentFuture.TrustedFuture<V> { static <V extends @Nullable Object> ListenableFuture<V> create( ListenableFuture<V> delegate, long time, TimeUnit unit, ScheduledExecutorService scheduledExecutor) {
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Fri Oct 25 13:13:32 UTC 2024 - 8.1K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/Futures.java
} else { collection = ImmutableList.copyOf(futures); } return (ListenableFuture<? extends T>[]) collection.toArray(new ListenableFuture<?>[0]); } // This can't be a TrustedFuture, because TrustedFuture has clever optimizations that // mean cancel won't be called if this Future is passed into setFuture, and then // cancelled. private static final class InCompletionOrderFuture<T extends @Nullable Object>
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Fri Oct 25 13:13:32 UTC 2024 - 64.7K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/AggregateFuture.java
@Override final void addInitialException(Set<Throwable> seen) { checkNotNull(seen); if (!isCancelled()) { /* * requireNonNull is safe because: * * - This is a TrustedFuture, so tryInternalFastPathGetFailure will in fact return the failure * cause if this Future has failed. * * - And this future *has* failed: This method is called only from handleException (through
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Fri Oct 25 13:13:32 UTC 2024 - 16.2K bytes - Viewed (0) -
guava/src/com/google/common/util/concurrent/Futures.java
} else { collection = ImmutableList.copyOf(futures); } return (ListenableFuture<? extends T>[]) collection.toArray(new ListenableFuture<?>[0]); } // This can't be a TrustedFuture, because TrustedFuture has clever optimizations that // mean cancel won't be called if this Future is passed into setFuture, and then // cancelled. private static final class InCompletionOrderFuture<T extends @Nullable Object>
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Fri Oct 25 13:13:32 UTC 2024 - 64.4K bytes - Viewed (0) -
guava/src/com/google/common/util/concurrent/FluentFuture.java
/** * A less abstract subclass of AbstractFuture. This can be used to optimize setFuture by ensuring * that {@link #get} calls exactly the implementation of {@link AbstractFuture#get}. */ abstract static class TrustedFuture<V extends @Nullable Object> extends FluentFuture<V> implements AbstractFuture.Trusted<V> { @CanIgnoreReturnValue @Override @ParametricNullness
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Sat Oct 19 00:51:36 UTC 2024 - 19.6K bytes - Viewed (0)