- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 37 for if (0.26 sec)
-
okhttp/src/main/kotlin/okhttp3/internal/connection/RealCall.kt
this.withLock { if (requestDone && requestBodyOpen || responseDone && responseBodyOpen) { if (requestDone) requestBodyOpen = false if (responseDone) responseBodyOpen = false bothStreamsDone = !requestBodyOpen && !responseBodyOpen callDone = !requestBodyOpen && !responseBodyOpen && !expectMoreExchanges } } if (bothStreamsDone) { this.exchange = null
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/RealConnection.kt
// If the non-host fields of the address don't overlap, we're done. if (!this.route.address.equalsNonHost(address)) return false // If the host exactly matches, we're done: this connection can carry the address. if (address.url.host == this.route().address.url.host) { return true // This connection is a perfect match. } // At this point we don't have a hostname match. But we still be able to carry the request if
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sat Apr 20 17:03:43 GMT 2024 - 15.4K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/http2/MockHttp2Peer.kt
for (i in 0 until frameCount) { if (nextOutFrame == null && outFramesIterator.hasNext()) { nextOutFrame = outFramesIterator.next() } if (nextOutFrame != null && nextOutFrame.sequence == i) { val start = nextOutFrame.start var truncated: Boolean var end: Long if (outFramesIterator.hasNext()) { nextOutFrame = outFramesIterator.next()
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Thu Apr 11 22:09:35 GMT 2024 - 8.7K bytes - Viewed (0) -
docs/changelogs/changelog_4x.md
## Version 4.11.0 _2023-04-22_ * Fix: Don't fail the call when the response code is ‘HTTP 102 Processing’ or ‘HTTP 103 Early Hints’. * Fix: Read the response even if writing the request fails. This means you'll get a proper HTTP response even if the server rejects your request body. * Fix: Use literal IP addresses directly rather than passing them to `DnsOverHttps`.
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Wed Apr 17 13:25:31 GMT 2024 - 25.2K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/publicsuffix/PublicSuffixListGenerator.kt
} } ImportResults(sortedRules, sortedExceptionRules, totalRuleBytes, totalExceptionRuleBytes) } private fun String.toRule(): ByteString? { if (trim { it <= ' ' }.isEmpty() || startsWith("//")) return null if (contains(WILDCARD_CHAR)) { assertWildcardRule(this) } return encodeUtf8() } data class ImportResults( val sortedRules: SortedSet<ByteString>,
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Thu Apr 18 01:24:38 GMT 2024 - 6K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/http2/Http2Writer.kt
val hpackWriter: Hpack.Writer = Hpack.Writer(out = hpackBuffer) @Throws(IOException::class) fun connectionPreface() { this.withLock { if (closed) throw IOException("closed") if (!client) return // Nothing to write; servers don't send connection headers! if (logger.isLoggable(FINE)) { logger.fine(format(">> CONNECTION ${CONNECTION_PREFACE.hex()}")) } sink.write(CONNECTION_PREFACE)
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sat Apr 20 17:03:43 GMT 2024 - 11.3K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/concurrent/TaskRunner.kt
* until one is ready. If there are no ready queues, or if other threads have everything under * control this will return null. If there is more than a single task ready to execute immediately * this will start another thread to handle that work. */ fun awaitTaskToRun(): Task? { lock.assertHeld() while (true) { if (readyQueues.isEmpty()) { return null // Nothing to do.
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Apr 29 00:33:04 GMT 2024 - 10.6K bytes - Viewed (0) -
build.gradle.kts
if (project.name == "okhttp-android") return@subprojects if (project.name == "android-test") return@subprojects if (project.name == "regression-test") return@subprojects if (project.name == "android-test-app") return@subprojects if (project.name == "container-tests") return@subprojects apply(plugin = "checkstyle") apply(plugin = "ru.vyarus.animalsniffer") apply(plugin = "biz.aQute.bnd.builder") tasks.withType<JavaCompile> {
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Thu Apr 18 01:32:42 GMT 2024 - 8.9K bytes - Viewed (0) -
okhttp-testing-support/src/main/kotlin/okhttp3/internal/concurrent/TaskFaker.kt
@Suppress("NOTHING_TO_INLINE") internal inline fun Any.assertThreadHoldsLock() { if (assertionsEnabled && !taskRunner.lock.isHeldByCurrentThread) { throw AssertionError("Thread ${Thread.currentThread().name} MUST hold lock on $this") } } @Suppress("NOTHING_TO_INLINE") internal inline fun Any.assertThreadDoesntHoldLock() { if (assertionsEnabled && taskRunner.lock.isHeldByCurrentThread) {
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Apr 29 00:33:04 GMT 2024 - 12.6K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/CacheControl.kt
@get:JvmName("minFreshSeconds") val minFreshSeconds: Int, /** * This field's name "only-if-cached" is misleading. It actually means "do not use the network". * It is set by a client who only wants to make a request if it can be fully satisfied by the * cache. Cached responses that would require validation (ie. conditional gets) are not permitted * if this header is set. */ @get:JvmName("onlyIfCached") val onlyIfCached: Boolean,
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Apr 15 13:41:01 GMT 2024 - 10K bytes - Viewed (0)