- Sort Score
- Result 10 results
- Languages All
Results 51 - 60 of 66 for Caller (0.18 sec)
-
okhttp/src/main/kotlin/okhttp3/internal/connection/RoutePlanner.kt
* certificate pin checks. */ fun sameHostAndPort(url: HttpUrl): Boolean /** * A plan holds either an immediately-usable connection, or one that must be connected first. * These steps are split so callers can call [connectTcp] on a background thread if attempting * multiple plans concurrently. */ interface Plan { val isReady: Boolean fun connectTcp(): ConnectResult
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Wed Dec 20 23:27:07 GMT 2023 - 4.2K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/Dispatcher.kt
call.cancel() } } } /** * Promotes eligible calls from [readyAsyncCalls] to [runningAsyncCalls] and runs them on the * executor service. Must not be called with synchronization because executing calls can call * into user code. * * @return true if the dispatcher is currently running calls. */ private fun promoteAndExecute(): Boolean {
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/Cookie.kt
* value. */ @get:JvmName("sameSite") val sameSite: String?, ) { /** * Returns true if this cookie should be included on a request to [url]. In addition to this * check callers should also confirm that this cookie has not expired. */ fun matches(url: HttpUrl): Boolean { val domainMatch = if (hostOnly) { url.host == domain } else {
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sat Apr 06 04:12:05 GMT 2024 - 23.1K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/cache/DiskLruCacheTest.kt
a.setString(0, "a1") assertThat(cache.remove("a")).isTrue() a.setString(1, "a2") a.commit() assertAbsent("a") } /** * Each read sees a snapshot of the file at the time read was called. This means that two reads of * the same key can see different data. */ @ParameterizedTest @ArgumentsSource(FileSystemParamProvider::class)
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Apr 15 14:55:09 GMT 2024 - 75.8K bytes - Viewed (0) -
mockwebserver-junit4/src/test/java/mockwebserver3/junit4/MockWebServerRuleTest.kt
val rule = MockWebServerRule() val called = AtomicBoolean() val statement: Statement = rule.apply( object : Statement() { override fun evaluate() { called.set(true) rule.server.url("/").toUrl().openConnection().connect() } }, Description.EMPTY, ) statement.evaluate() assertThat(called.get()).isTrue() try {
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 1.5K bytes - Viewed (1) -
mockwebserver/src/main/kotlin/mockwebserver3/MockWebServer.kt
import okio.Buffer import okio.BufferedSink import okio.BufferedSource import okio.Sink import okio.Timeout import okio.buffer import okio.sink import okio.source /** * A scriptable web server. Callers supply canned responses and the server replays them upon request * in sequence. */ @ExperimentalOkHttpApi class MockWebServer : Closeable { private val taskRunnerBackend = TaskRunner.RealBackend(
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sun Mar 31 17:16:15 GMT 2024 - 37.4K bytes - Viewed (0) -
okhttp-dnsoverhttps/src/main/kotlin/okhttp3/dnsoverhttps/BootstrapDns.kt
) : Dns { @Throws(UnknownHostException::class) override fun lookup(hostname: String): List<InetAddress> { if (this.dnsHostname != hostname) { throw UnknownHostException( "BootstrapDns called for $hostname instead of $dnsHostname", ) } return dnsServers }
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 1.3K bytes - Viewed (2) -
samples/guide/src/main/java/okhttp3/recipes/PostStreamingWithPipe.java
thread.start(); } /** * This request body makes it possible for another thread to stream data to the uploading request. * This is potentially useful for posting live event streams like video capture. Callers should * write to {@code sink()} and close it to complete the post. */ static final class PipeBody extends RequestBody { private final Pipe pipe = new Pipe(8192);
Java - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Fri Jul 06 03:18:15 GMT 2018 - 3.1K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/connection/RealConnectionPool.kt
} return 0L // run again immediately to create more connections if needed } catch (e: IOException) { // No need to log, user.connectFailed() will already have been called. Just try again later. return state.policy.backoffDelayMillis.jitterBy(state.policy.backoffJitterMillis) * 1_000_000 } } private fun Long.jitterBy(amount: Int): Long {
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sat Apr 20 17:03:43 GMT 2024 - 16.2K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/http/HttpMethod.kt
object HttpMethod { @JvmStatic // Despite being 'internal', this method is called by popular 3rd party SDKs. fun invalidatesCache(method: String): Boolean = ( method == "POST" || method == "PATCH" || method == "PUT" || method == "DELETE" || method == "MOVE" ) @JvmStatic // Despite being 'internal', this method is called by popular 3rd party SDKs. fun requiresRequestBody(method: String): Boolean = (
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 1.5K bytes - Viewed (0)