- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 12 for resync (0.21 sec)
-
regression-test/src/androidTest/java/okhttp/regression/compare/ApacheHttpClientHttp2Test.kt
* <http://www.apache.org/>. * */ package okhttp.regression.compare import org.apache.hc.client5.http.async.methods.SimpleHttpRequests import org.apache.hc.client5.http.async.methods.SimpleHttpResponse import org.apache.hc.client5.http.impl.async.HttpAsyncClients import org.apache.hc.core5.concurrent.FutureCallback import org.apache.hc.core5.http.ProtocolVersion import org.junit.Assert
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 2.6K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/connection/RealCall.kt
get() = originalRequest.url.host val request: Request get() = originalRequest val call: RealCall get() = this@RealCall /** * Attempt to enqueue this async call on [executorService]. This will attempt to clean up * if the executor has been shut down by reporting the call as failed. */ fun executeOn(executorService: ExecutorService) {
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sat Apr 20 17:03:43 GMT 2024 - 17.9K bytes - Viewed (2) -
okhttp/src/main/kotlin/okhttp3/internal/connection/InetAddressOrder.kt
import java.net.Inet6Address import java.net.InetAddress import okhttp3.internal.interleave /** * Implementation of HappyEyeballs Sorting Addresses. * * The current implementation does not address any of: * - Async DNS split by IP class * - Stateful handling of connectivity results * - The prioritisation of addresses * * https://datatracker.ietf.org/doc/html/rfc8305#section-4 */
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Wed Dec 20 23:27:07 GMT 2023 - 1.3K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/CallTest.kt
assertThat(expected.message).isEqualTo("Already Executed") } assertThat(server.takeRequest().headers["User-Agent"]).isEqualTo("SyncApiTest") } @Test fun illegalToExecuteTwice_Async() { server.enqueue( MockResponse( headers = headersOf("Content-Type", "text/plain"), body = "abc", ), ) val request = Request.Builder()
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Wed Apr 10 19:46:48 GMT 2024 - 142.5K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/connection/ConnectPlan.kt
) } override fun connectTcp(): ConnectResult { check(rawSocket == null) { "TCP already connected" } var success = false // Tell the call about the connecting call so async cancels work. user.addPlanToCancel(this) try { user.connectStart(route) connectSocket() success = true return ConnectResult(plan = this) } catch (e: IOException) {
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sat Apr 20 17:03:43 GMT 2024 - 18.6K bytes - Viewed (0) -
kotlin-js-store/yarn.lock
integrity sha512-+EUsqGPLsM+j/zdChZjsnX51g4XrHFOIXwfnCVPGlQk/k5giakcKsuxCObBRu6DSm9opw/O6slWbJdghQM4bBg== neo-async@^2.6.2: version "2.6.2" resolved "https://registry.yarnpkg.com/neo-async/-/neo-async-2.6.2.tgz#b4aafb93e3aeb2d8174ca53cf163ab7d7308305f" integrity sha512-Yd3UES5mWCSqR+qNT93S3UoYUkqAZ9lLg8a7g9rimsWmYGK8cVToA4/sF3RrshdyV3sAGMXVUmpMYOw+dLpOuw==
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sat Jul 22 12:28:51 GMT 2023 - 87.4K bytes - Viewed (0) -
docs/changelogs/changelog_3x.md
If your application uses `HttpURLConnection.connect()`, `setFixedLengthStreamingMode()`, or `setChunkedStreamingMode()`, OkHttp will now use a async dispatcher thread to establish the HTTP connection. We don’t expect this change to have any behavior or performance consequences. Regardless, please exercise your `OkUrlFactory` and
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sun Feb 06 14:55:54 GMT 2022 - 50.8K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/Dispatcher.kt
import okhttp3.internal.connection.RealCall import okhttp3.internal.connection.RealCall.AsyncCall import okhttp3.internal.okHttpName import okhttp3.internal.threadFactory /** * Policy on when async requests are executed. * * Each dispatcher uses an [ExecutorService] to run calls internally. If you supply your own * executor, it should be able to run [the configured maximum][maxRequests] number of calls * concurrently.
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sat Apr 20 17:03:43 GMT 2024 - 9K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/AsyncDns.kt
* */ package okhttp3 import java.net.InetAddress import java.net.UnknownHostException import java.util.concurrent.CountDownLatch import okio.IOException /** * An async domain name service that resolves IP addresses for host names. * * The main implementations will typically be implemented using specific DNS libraries such as * * Android DnsResolver * * OkHttp DnsOverHttps
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Tue Jan 23 14:31:42 GMT 2024 - 3.5K bytes - Viewed (0) -
README.md
configured to fall back for broad connectivity. Using OkHttp is easy. Its request/response API is designed with fluent builders and immutability. It supports both synchronous blocking calls and async calls with callbacks. Get a URL --------- This program downloads a URL and prints its contents as a string. [Full source][get_example]. ```java OkHttpClient client = new OkHttpClient();
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Wed Dec 20 23:27:07 GMT 2023 - 6.2K bytes - Viewed (0)