- Sort Score
- Num 10 results
- Language All
Results 1 - 7 of 7 for CompletableFuture (0.11 seconds)
-
android/guava/src/com/google/common/util/concurrent/FluentFuture.java
* </ul> * * <h4>{@link java.util.concurrent.CompletableFuture} / {@link java.util.concurrent.CompletionStage} * </h4> * * <p>Users of {@code CompletableFuture} will likely want to continue using {@code * CompletableFuture}. {@code FluentFuture} is targeted at people who use {@code ListenableFuture}, * who can't use Java 8, or who want an API more focused than {@code CompletableFuture}. (If you
Created: Fri Dec 26 12:43:10 GMT 2025 - Last Modified: Thu Aug 07 16:05:33 GMT 2025 - 19.7K bytes - Click Count (0) -
regression-test/src/androidTest/java/okhttp/regression/compare/AndroidHttpEngineTest.kt
val negotiatedProtocol: String, val content: String, ) private fun execute( engine: HttpEngine, executor: ExecutorService, url: String, ): CompletableFuture<Response> { val completableFuture = CompletableFuture<Response>() val buffer = Buffer() val req = engine .newUrlRequestBuilder( url, executor, object : Callback {Created: Fri Dec 26 11:42:13 GMT 2025 - Last Modified: Wed Mar 19 19:25:20 GMT 2025 - 6.3K bytes - Click Count (0) -
okhttp/src/jvmTest/kotlin/okhttp3/internal/http/ThreadInterruptTest.kt
import assertk.assertions.startsWith import assertk.fail import java.io.IOException import java.net.ServerSocket import java.net.Socket import java.net.SocketException import java.util.concurrent.CompletableFuture import java.util.concurrent.RejectedExecutionException import java.util.concurrent.TimeUnit import kotlin.test.assertFailsWith import okhttp3.Call import okhttp3.Callback import okhttp3.DelegatingServerSocketFactory
Created: Fri Dec 26 11:42:13 GMT 2025 - Last Modified: Tue Nov 04 18:33:48 GMT 2025 - 6.4K bytes - Click Count (0) -
okhttp/src/jvmTest/kotlin/okhttp3/SocketChannelTest.kt
import assertk.assertThat import assertk.assertions.isEqualTo import assertk.assertions.isNotEmpty import assertk.assertions.isNotNull import java.io.IOException import java.net.InetAddress import java.util.concurrent.CompletableFuture import java.util.concurrent.TimeUnit.SECONDS import javax.net.ssl.SNIHostName import javax.net.ssl.SNIMatcher import javax.net.ssl.SNIServerName import javax.net.ssl.SSLSocket import javax.net.ssl.StandardConstants
Created: Fri Dec 26 11:42:13 GMT 2025 - Last Modified: Sat Nov 01 12:18:11 GMT 2025 - 7.9K bytes - Click Count (0) -
android/guava/src/com/google/common/util/concurrent/JdkFutureAdapters.java
* that, whenever possible, it is strongly preferred to modify those libraries to return {@code * ListenableFuture} directly. * * <p>For interoperability between {@code ListenableFuture} and <b>{@code CompletableFuture}</b>, * consider <a href="https://github.com/lukas-krecan/future-converter">Future Converter</a>. * * @author Sven Mawson * @since 10.0 (replacing {@code Futures.makeListenable}, which existed in 1.0) */Created: Fri Dec 26 12:43:10 GMT 2025 - Last Modified: Thu Jul 17 15:26:41 GMT 2025 - 7.5K bytes - Click Count (0) -
android/guava/src/com/google/common/cache/CacheBuilder.java
* * <p>Caffeine's API for asynchronous operations uses {@code CompletableFuture}: <a * href="https://www.javadoc.io/doc/com.github.ben-manes.caffeine/caffeine/latest/com.github.benmanes.caffeine/com/github/benmanes/caffeine/cache/AsyncLoadingCache.html#get(K)">{@code * AsyncLoadingCache.get}</a> returns a {@code CompletableFuture}, and implementations of <a
Created: Fri Dec 26 12:43:10 GMT 2025 - Last Modified: Wed Oct 08 18:55:33 GMT 2025 - 51.9K bytes - Click Count (0) -
guava/src/com/google/common/cache/CacheBuilder.java
* * <p>Caffeine's API for asynchronous operations uses {@code CompletableFuture}: <a * href="https://www.javadoc.io/doc/com.github.ben-manes.caffeine/caffeine/latest/com.github.benmanes.caffeine/com/github/benmanes/caffeine/cache/AsyncLoadingCache.html#get(K)">{@code * AsyncLoadingCache.get}</a> returns a {@code CompletableFuture}, and implementations of <a
Created: Fri Dec 26 12:43:10 GMT 2025 - Last Modified: Wed Oct 08 18:55:33 GMT 2025 - 51.6K bytes - Click Count (0)