- Sort Score
- Result 10 results
- Languages All
Results 1 - 7 of 7 for executeAsync (1.23 sec)
-
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) -
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) -
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) -
okhttp-coroutines/README.md
OkHttp Coroutines ================= Support for Kotlin clients using coroutines. ```kotlin val call = client.newCall(request) call.executeAsync().use { response -> withContext(Dispatchers.IO) { println(response.body?.string()) } } ``` This is implemented using `suspendCancellableCoroutine` but uses the standard Dispatcher in OkHttp. This means that by default Kotlin's Dispatchers are not used.
Registered: Fri Dec 26 11:42:13 UTC 2025 - Last Modified: Thu Nov 09 15:47:27 UTC 2023 - 609 bytes - Viewed (0) -
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) -
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) -
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)