Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 8 of 8 for executeAsync (0.3 sec)

  1. okhttp-coroutines/src/main/kotlin/okhttp3/coroutines/ExecuteAsync.kt

    import kotlinx.coroutines.suspendCancellableCoroutine
    import okhttp3.Call
    import okhttp3.Callback
    import okhttp3.Response
    import okhttp3.internal.closeQuietly
    import okio.IOException
    
    suspend fun Call.executeAsync(): Response =
      suspendCancellableCoroutine { continuation ->
        continuation.invokeOnCancellation {
          this.cancel()
        }
        this.enqueue(
          object : Callback {
            override fun onFailure(
    Registered: Fri Dec 26 11:42:13 UTC 2025
    - Last Modified: Thu Jun 19 04:20:30 UTC 2025
    - 1.4K bytes
    - Viewed (1)
  2. okhttp-coroutines/src/test/kotlin/okhttp3/coroutines/ExecuteAsyncTest.kt

      val request by lazy { Request(server.url("/")) }
    
      @Test
      fun suspendCall() {
        runTest {
          server.enqueue(MockResponse(body = "abc"))
    
          val call = client.newCall(request)
    
          call.executeAsync().use {
            withContext(Dispatchers.IO) {
              assertThat(it.body.string()).isEqualTo("abc")
            }
          }
        }
      }
    
      @Test
      fun timeoutCall() {
        runTest {
          server.enqueue(
    Registered: Fri Dec 26 11:42:13 UTC 2025
    - Last Modified: Fri Jun 20 11:46:46 UTC 2025
    - 5.3K bytes
    - Viewed (0)
  3. samples/tlssurvey/src/main/kotlin/okhttp3/survey/Iana.kt

     * limitations under the License.
     */
    package okhttp3.survey
    
    import okhttp3.HttpUrl.Companion.toHttpUrl
    import okhttp3.OkHttpClient
    import okhttp3.Request
    import okhttp3.coroutines.executeAsync
    import okhttp3.survey.types.SuiteId
    import okio.ByteString.Companion.decodeHex
    import okio.IOException
    
    /** Example: "0x00,0x08",TLS_RSA_EXPORT_WITH_DES40_CBC_SHA,Y,N,[RFC4346] */
    Registered: Fri Dec 26 11:42:13 UTC 2025
    - Last Modified: Wed Mar 19 19:25:20 UTC 2025
    - 2K bytes
    - Viewed (0)
  4. okhttp-coroutines/api/okhttp-coroutines.api

    public final class okhttp3/coroutines/ExecuteAsyncKt {
    	public static final fun executeAsync (Lokhttp3/Call;Lkotlin/coroutines/Continuation;)Ljava/lang/Object;
    Registered: Fri Dec 26 11:42:13 UTC 2025
    - Last Modified: Thu Apr 18 01:24:38 UTC 2024
    - 163 bytes
    - Viewed (0)
  5. okhttp/src/jvmTest/kotlin/okhttp3/internal/publicsuffix/PublicSuffixListGenerator.kt

    import java.util.TreeSet
    import kotlinx.coroutines.Dispatchers
    import kotlinx.coroutines.withContext
    import okhttp3.HttpUrl.Companion.toHttpUrl
    import okhttp3.OkHttpClient
    import okhttp3.Request
    import okhttp3.coroutines.executeAsync
    import okhttp3.internal.publicsuffix.ResourcePublicSuffixList.Companion.PUBLIC_SUFFIX_RESOURCE
    import okio.BufferedSink
    import okio.ByteString
    import okio.ByteString.Companion.encodeUtf8
    import okio.FileSystem
    Registered: Fri Dec 26 11:42:13 UTC 2025
    - Last Modified: Wed Aug 06 05:33:11 UTC 2025
    - 6.1K bytes
    - Viewed (0)
  6. okhttp/src/androidMain/baseline-prof.txt

    HSPLokhttp3/JvmCallExtensionsKt$executeAsync$2$1;-><init>(Lokhttp3/Call;)V
    HSPLokhttp3/JvmCallExtensionsKt$executeAsync$2$2$onResponse$1;-><init>(Lokhttp3/Call;)V
    HSPLokhttp3/JvmCallExtensionsKt$executeAsync$2$2;-><init>(Lkotlinx/coroutines/CancellableContinuation;)V
    HSPLokhttp3/JvmCallExtensionsKt$executeAsync$2$2;->onFailure(Lokhttp3/Call;Ljava/io/IOException;)V
    Registered: Fri Dec 26 11:42:13 UTC 2025
    - Last Modified: Mon Dec 30 23:28:56 UTC 2024
    - 127.9K bytes
    - Viewed (1)
  7. CHANGELOG.md

        for a graceful shutdown before it performs an abrupt shutdown.
    
     *  Fix: Honor `RequestBody.isOneShot()` in `MultipartBody`
    
     *  Fix in `okhttp-coroutines`: Don't leak response bodies in `executeAsync()`. We had a bug where
        we didn't call `Response.close()` if the coroutine was canceled before its response was
        returned.
    
     *  Upgrade: [Okio 3.9.0][okio_3_9_0].
    
    Registered: Fri Dec 26 11:42:13 UTC 2025
    - Last Modified: Fri Dec 05 16:02:59 UTC 2025
    - 36.2K bytes
    - Viewed (2)
  8. CLAUDE.md

    2. **Factory Pattern**: `Curl` class provides static factory methods for each HTTP method
    3. **Resource Management**: `CurlResponse` implements `Closeable` for try-with-resources
    4. **Async Support**: Both synchronous (`executeSync()`) and asynchronous (`execute()`) execution modes
    
    ## Technical Details
    
    - **Java Version**: 17+
    - **Dependencies**:
      - Apache Commons IO 2.19.0 (runtime)
      - JUnit 4.13.2 (test)
    Registered: Sat Dec 20 09:13:53 UTC 2025
    - Last Modified: Mon Nov 24 03:10:07 UTC 2025
    - 3.2K bytes
    - Viewed (0)
Back to top