- Sort Score
- Result 10 results
- Languages All
Results 361 - 370 of 755 for future (0.03 sec)
-
okhttp/src/jvmTest/kotlin/okhttp3/CallTest.kt
* connection that returns to the connection pool with the underlying socket closed. This relies * on an implementation detail so it might not be a valid test case in the future. */ @Test fun cancelAfterResponseBodyEnd() { enableTls() server.enqueue(MockResponse(body = "abc")) server.enqueue(MockResponse(body = "def")) client = client
Registered: Fri Dec 26 11:42:13 UTC 2025 - Last Modified: Tue Nov 04 19:13:52 UTC 2025 - 147.4K bytes - Viewed (0) -
docs/bucket/versioning/README.md
> NOTE: Server side replication is supported for idempotent versions on delete marked objects. ### Motivation
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Tue Aug 12 18:20:36 UTC 2025 - 12K bytes - Viewed (0) -
docs/smb3-features/02-persistent-handles-design.md
```java public class BatchHandleOperations { public void reconnectMultipleHandles(List<HandleInfo> handles) { List<CompletableFuture<Void>> futures = new ArrayList<>(); for (HandleInfo handle : handles) { futures.add(CompletableFuture.runAsync(() -> { try { reconnectHandle(handle); } catch (Exception e) {Registered: Sat Dec 20 13:44:44 UTC 2025 - Last Modified: Sat Aug 16 02:53:50 UTC 2025 - 31.6K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/FuturesGetDoneTest.java
import static com.google.common.util.concurrent.Futures.getDone; import static com.google.common.util.concurrent.Futures.immediateCancelledFuture; import static com.google.common.util.concurrent.Futures.immediateFailedFuture; import static com.google.common.util.concurrent.Futures.immediateFuture; import static com.google.common.util.concurrent.Futures.immediateVoidFuture;
Registered: Fri Dec 26 12:43:10 UTC 2025 - Last Modified: Tue Sep 23 01:35:55 UTC 2025 - 2.3K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/GwtFuturesCatchingSpecialization.java
import com.google.common.annotations.J2ktIncompatible; /** * Hidden superclass of {@link Futures} that provides us a place to declare special GWT versions of * the {@link Futures#catching(ListenableFuture, Class, com.google.common.base.Function, * java.util.concurrent.Executor) Futures.catching} family of methods. Those versions have slightly * different signatures. */ @GwtCompatibleRegistered: Fri Dec 26 12:43:10 UTC 2025 - Last Modified: Thu Aug 07 16:05:33 UTC 2025 - 1.4K bytes - Viewed (0) -
guava-gwt/src-super/com/google/common/util/concurrent/super/com/google/common/util/concurrent/GwtFuturesCatchingSpecialization.java
import java.util.concurrent.Executor; import org.jspecify.annotations.Nullable; /** * Hidden superclass of {@link Futures} that provides us a place to declare special GWT versions of * the {@link Futures#catching(ListenableFuture, Class, com.google.common.base.Function) * Futures.catching} family of methods. Those versions have slightly different signatures. */ abstract class GwtFuturesCatchingSpecialization { /*Registered: Fri Dec 26 12:43:10 UTC 2025 - Last Modified: Sun Dec 22 03:38:46 UTC 2024 - 2K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/FuturesTransformTest.java
package com.google.common.util.concurrent; import static com.google.common.util.concurrent.Futures.transform; import static com.google.common.util.concurrent.MoreExecutors.directExecutor; import com.google.common.base.Function; import java.lang.reflect.UndeclaredThrowableException; import org.jspecify.annotations.NullUnmarked; /** * Unit tests for {@link Futures#transform(ListenableFuture, Function, Executor)}. * * @author Nishant ThakkarRegistered: Fri Dec 26 12:43:10 UTC 2025 - Last Modified: Thu Dec 19 18:03:30 UTC 2024 - 2K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/FuturesTransformAsyncTest.java
*/ package com.google.common.util.concurrent; import static com.google.common.truth.Truth.assertThat; import static com.google.common.util.concurrent.Futures.immediateFuture; import static com.google.common.util.concurrent.Futures.transformAsync; import static com.google.common.util.concurrent.MoreExecutors.directExecutor; import static com.google.common.util.concurrent.Uninterruptibles.awaitUninterruptibly;
Registered: Fri Dec 26 12:43:10 UTC 2025 - Last Modified: Thu Dec 11 20:07:52 UTC 2025 - 6.4K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/FuturesTransformAsyncTest.java
*/ package com.google.common.util.concurrent; import static com.google.common.truth.Truth.assertThat; import static com.google.common.util.concurrent.Futures.immediateFuture; import static com.google.common.util.concurrent.Futures.transformAsync; import static com.google.common.util.concurrent.MoreExecutors.directExecutor; import static com.google.common.util.concurrent.Uninterruptibles.awaitUninterruptibly;
Registered: Fri Dec 26 12:43:10 UTC 2025 - Last Modified: Thu Dec 11 20:07:52 UTC 2025 - 6.4K bytes - Viewed (0) -
guava/src/com/google/common/util/concurrent/GwtFuturesCatchingSpecialization.java
import com.google.common.annotations.J2ktIncompatible; /** * Hidden superclass of {@link Futures} that provides us a place to declare special GWT versions of * the {@link Futures#catching(ListenableFuture, Class, com.google.common.base.Function, * java.util.concurrent.Executor) Futures.catching} family of methods. Those versions have slightly * different signatures. */ @GwtCompatibleRegistered: Fri Dec 26 12:43:10 UTC 2025 - Last Modified: Thu Aug 07 16:05:33 UTC 2025 - 1.4K bytes - Viewed (0)