Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 1 - 7 of 7 for CompletableFuture (0.11 seconds)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
Back to Top