- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 63 for fallback (0.22 sec)
-
android/guava/src/com/google/common/util/concurrent/FluentFuture.java
* java.util.concurrent.CompletableFuture#thenAcceptAsync}. * * @param callback The callback to invoke when this {@code Future} is completed. * @param executor The executor to run {@code callback} when the future completes. */ public final void addCallback(FutureCallback<? super V> callback, Executor executor) { Futures.addCallback(this, callback, executor); }
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Tue Apr 11 19:08:44 GMT 2023 - 18.7K bytes - Viewed (0) -
guava-gwt/src-super/com/google/common/util/concurrent/super/com/google/common/util/concurrent/GwtFluentFutureCatchingSpecialization.java
Class<Throwable> exceptionType, Function<? super Throwable, ? extends V> fallback, Executor executor) { return (FluentFuture<V>) Futures.catching(this, exceptionType, fallback, executor); } public final FluentFuture<V> catchingAsync( Class<Throwable> exceptionType, AsyncFunction<? super Throwable, ? extends V> fallback, Executor executor) {
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Thu Dec 08 20:30:27 GMT 2022 - 1.9K bytes - Viewed (0) -
guava-tests/test/com/google/common/base/OptionalTest.java
public void testOr_supplier_present() { assertEquals("a", Optional.of("a").or(Suppliers.ofInstance("fallback"))); } public void testOr_supplier_absent() { assertEquals("fallback", Optional.absent().or(Suppliers.ofInstance("fallback"))); } public void testOr_nullSupplier_absent() {
Java - Registered: Fri Apr 19 12:43:09 GMT 2024 - Last Modified: Wed Feb 21 18:32:41 GMT 2024 - 11.2K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/AggregateFutureStateFallbackAtomicHelperTest.java
* and performant but introduces some testing difficulties. This test exercises the two fallback * strategies. * * <ul> * <li>SafeAtomicHelper: uses Atomic FieldsUpdaters to implement synchronization * <li>SynchronizedHelper: uses {@code synchronized} blocks for synchronization * </ul> * * To force selection of our fallback strategies we load {@link AggregateFutureState} (and all of
Java - Registered: Fri Apr 12 12:43:09 GMT 2024 - Last Modified: Mon Oct 10 19:45:10 GMT 2022 - 5.9K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/FuturesTest.java
output.cancel(false); throw new MyRuntimeException(); } } Fallback fallback = new Fallback(); SettableFuture<Object> input = SettableFuture.create(); ListenableFuture<Object> output = catching(input, Throwable.class, fallback, directExecutor()); fallback.output = output; input.setException(new MyException()); assertTrue(output.isCancelled()); }
Java - Registered: Fri Apr 12 12:43:09 GMT 2024 - Last Modified: Tue Feb 20 17:00:05 GMT 2024 - 144.5K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/base/OptionalTest.java
public void testOr_supplier_present() { assertEquals("a", Optional.of("a").or(Suppliers.ofInstance("fallback"))); } public void testOr_supplier_absent() { assertEquals("fallback", Optional.absent().or(Suppliers.ofInstance("fallback"))); } public void testOr_nullSupplier_absent() {
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Wed Feb 21 18:32:41 GMT 2024 - 10.5K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/FuturesTest.java
output.cancel(false); throw new MyRuntimeException(); } } Fallback fallback = new Fallback(); SettableFuture<Object> input = SettableFuture.create(); ListenableFuture<Object> output = catching(input, Throwable.class, fallback, directExecutor()); fallback.output = output; input.setException(new MyException()); assertTrue(output.isCancelled()); }
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Tue Feb 20 17:00:05 GMT 2024 - 144.5K bytes - Viewed (0) -
guava-gwt/src-super/com/google/common/util/concurrent/super/com/google/common/util/concurrent/GwtFuturesCatchingSpecialization.java
Function<? super Throwable, ? extends V> fallback, Executor executor) { return AbstractCatchingFuture.create(input, exceptionType, fallback, executor); } public static <V extends @Nullable Object> ListenableFuture<V> catchingAsync( ListenableFuture<? extends V> input, Class<Throwable> exceptionType, AsyncFunction<? super Throwable, ? extends V> fallback, Executor executor) {
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Thu Dec 08 20:30:27 GMT 2022 - 2K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/Futures.java
* * @param future The future attach the callback to. * @param callback The callback to invoke when {@code future} is completed. * @param executor The executor to run {@code callback} when the future completes. * @since 10.0 */ public static <V extends @Nullable Object> void addCallback( final ListenableFuture<V> future, final FutureCallback<? super V> callback, Executor executor) {
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Mon Apr 01 16:15:01 GMT 2024 - 59.6K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/AbstractFutureFallbackAtomicHelperTest.java
* introduces some testing difficulties. This test exercises the two fallback strategies in abstract * future. * * <ul> * <li>SafeAtomicHelper: uses AtomicReferenceFieldsUpdaters to implement synchronization * <li>SynchronizedHelper: uses {@code synchronized} blocks for synchronization * </ul> * * To force selection of our fallback strategies we load {@link AbstractFuture} (and all of {@code
Java - Registered: Fri Apr 12 12:43:09 GMT 2024 - Last Modified: Tue Feb 16 03:24:50 GMT 2021 - 6.2K bytes - Viewed (0)