- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 223 for true (0.13 sec)
-
okhttp/src/main/kotlin/okhttp3/internal/connection/RealConnection.kt
/** * If true, no new exchanges can be created on this connection. It is necessary to set this to * true when removing a connection from the pool; otherwise a racing caller might get it from the * pool when it shouldn't. Symmetrically, this must always be checked before returning a * connection from the pool. * * Once true this is always true. Guarded by this. */ var noNewExchanges = false
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/main/kotlin/okhttp3/internal/connection/RealCall.kt
/** True if this call still has a request body open. */ private var requestBodyOpen = false /** True if this call still has a response body open. */ private var responseBodyOpen = false /** True if there are more exchanges expected for this call. */ private var expectMoreExchanges = true
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/-HostnamesCommon.kt
internal fun String.containsInvalidLabelLengths(): Boolean { if (length !in 1..253) return true var labelStart = 0 while (true) { val dot = indexOf('.', startIndex = labelStart) val labelLength = when (dot) { -1 -> length - labelStart else -> dot - labelStart } if (labelLength !in 1..63) return true if (dot == -1) break if (dot == length - 1) break // Trailing '.' is allowed.
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 11.2K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/idn/Punycode.kt
* * @return true if the range of [string] from [pos] to [limit] was valid and decoded successfully. * Otherwise, the decode failed. */ private fun decodeLabel( string: String, pos: Int, limit: Int, result: Buffer, ): Boolean { if (!string.regionMatches(pos, PREFIX_STRING, 0, 4, ignoreCase = true)) { result.writeUtf8(string, pos, limit)
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Wed Apr 03 03:04:50 GMT 2024 - 8.5K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/ResponseBodyJvmTest.kt
val source = Buffer().writeUtf8("hello") return object : ForwardingSource(source) { @Throws(IOException::class) override fun close() { closed.set(true) super.close() } }.buffer() } } assertThat(body.string()).isEqualTo("hello") assertThat(closed.get()).isTrue() } @Test
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 13K bytes - Viewed (0) -
okhttp-java-net-cookiejar/src/main/kotlin/okhttp3/java/net/cookiejar/JavaNetCookieJar.kt
return emptyList() } var cookies: MutableList<Cookie>? = null for ((key, value) in cookieHeaders) { if (("Cookie".equals(key, ignoreCase = true) || "Cookie2".equals(key, ignoreCase = true)) && value.isNotEmpty() ) { for (header in value) { if (cookies == null) cookies = mutableListOf() cookies.addAll(decodeHeaderAsJavaNetCookies(url, header))
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sat Apr 06 04:10:43 GMT 2024 - 3.8K bytes - Viewed (0) -
okhttp-testing-support/src/main/kotlin/okhttp3/RecordingConnectionListener.kt
open class RecordingConnectionListener( /** * An override to ignore the normal order that is enforced. * EventListeners added by Interceptors will not see all events. */ private val enforceOrder: Boolean = true, ) : ConnectionListener() { val eventSequence: Deque<ConnectionEvent> = ConcurrentLinkedDeque() private val forbiddenLocks = mutableSetOf<Any>()
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 5.6K bytes - Viewed (0) -
okhttp-logging-interceptor/src/main/kotlin/okhttp3/logging/HttpLoggingInterceptor.kt
private fun bodyHasUnknownEncoding(headers: Headers): Boolean { val contentEncoding = headers["Content-Encoding"] ?: return false return !contentEncoding.equals("identity", ignoreCase = true) && !contentEncoding.equals("gzip", ignoreCase = true) } private fun bodyIsStreaming(response: Response): Boolean { val contentType = response.body.contentType()
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sat Apr 06 09:14:38 GMT 2024 - 11.2K bytes - Viewed (1) -
okhttp-idna-mapping-table/src/main/kotlin/okhttp3/internal/idn/SimpleIdnaMappingTable.kt
* [mapping step]: https://www.unicode.org/reports/tr46/#ProcessingStepMap */ class SimpleIdnaMappingTable internal constructor( internal val mappings: List<Mapping>, ) { /** * Returns true if the [codePoint] was applied successfully. Returns false if it was disallowed. */ fun map( codePoint: Int, sink: BufferedSink, ): Boolean { val index = mappings.binarySearch {
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 6.8K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/ws/WebSocketWriterTest.kt
sink = data, random = random, perMessageDeflate = false, noContextTakeover = false, minimumDeflateSize = 0L, ) private val clientWriter = WebSocketWriter( isClient = true, sink = data, random = random, perMessageDeflate = false, noContextTakeover = false, minimumDeflateSize = 0L, ) @Test fun serverTextMessage() {
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 9.3K bytes - Viewed (0)