- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 58 for continuum (0.17 sec)
-
okhttp-idna-mapping-table/src/main/kotlin/okhttp3/internal/idn/SimpleIdnaMappingTable.kt
while (!exhausted()) { // Skip comment and empty lines. when (select(optionsDelimiter)) { DELIMITER_HASH -> { skipRestOfLine() continue } DELIMITER_NEWLINE -> { continue } DELIMITER_DOT, DELIMITER_SPACE, DELIMITER_SEMICOLON -> { throw IOException("unexpected delimiter") } } // "002F" or "0000..002C"
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-hpacktests/src/test/java/okhttp3/internal/http2/HpackDecodeTestBase.kt
private val bytesIn = Buffer() private val hpackReader = Hpack.Reader(bytesIn, 4096) protected fun testDecoder(story: Story) { for (testCase in story.cases) { val encoded = testCase.wire ?: continue bytesIn.write(encoded) hpackReader.readHeaders() assertSetEquals( "seqno=$testCase.seqno", testCase.headersList, hpackReader.getAndResetHeaderList(), ) }
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 2.2K bytes - Viewed (0) -
okhttp-java-net-cookiejar/src/main/kotlin/okhttp3/java/net/cookiejar/JavaNetCookieJar.kt
val equalsSign = header.delimiterOffset('=', pos, pairEnd) val name = header.trimSubstring(pos, equalsSign) if (name.startsWith("$")) { pos = pairEnd + 1 continue } // We have either name=value or just a name. var value = if (equalsSign < pairEnd) { header.trimSubstring(equalsSign + 1, pairEnd) } else { ""
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
eventSequence.forEach loop@{ when (e.closes(it)) { null -> return // no open event true -> return // found open event false -> return@loop // this is not the open event so continue } } Assertions.fail<Any>("event $e without matching start event") } } override fun connectStart( route: Route, call: Call,
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/src/test/java/okhttp3/internal/publicsuffix/PublicSuffixListGenerator.kt
var totalExceptionRuleBytes = 0 fileSystem.source(publicSuffixListDotDat).buffer().use { source -> while (!source.exhausted()) { var rule: ByteString = source.readUtf8LineStrict().toRule() ?: continue if (rule.startsWith(EXCEPTION_RULE_MARKER)) { rule = rule.substring(1) // We use '\n' for end of value. totalExceptionRuleBytes += rule.size + 1
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/cache2/Relay.kt
if (complete) return -1L // Another thread is already reading. Wait for that. if (upstreamReader != null) { timeout.waitUntilNotified(this@Relay) continue } // We will do the read. upstreamReader = Thread.currentThread() return@synchronized SOURCE_UPSTREAM }
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 11.8K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/tls/OkHostnameVerifier.kt
val result = mutableListOf<String>() for (subjectAltName in subjectAltNames) { if (subjectAltName == null || subjectAltName.size < 2) continue if (subjectAltName[0] != type) continue val altName = subjectAltName[1] ?: continue result.add(altName as String) } return result } catch (_: CertificateParsingException) { return emptyList() } }
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Apr 15 14:55:09 GMT 2024 - 7.7K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/connection/FastFallbackExchangeFinder.kt
} // Wait for an in-flight connect to complete or fail. if (connectResult == null) { connectResult = awaitTcpConnect(awaitTimeoutNanos, TimeUnit.NANOSECONDS) ?: continue } if (connectResult.isSuccess) { // We have a connected TCP connection. Cancel and defer the racing connects that all lost. cancelInFlightConnects()
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 5.8K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/http/HttpHeaders.kt
result.add( Challenge( schemeName, Collections.singletonMap<String, String>(null, peek + "=".repeat(eqCount)), ), ) peek = null continue } // It's a series of parameter names and values. val parameters = mutableMapOf<String?, String>() eqCount += skipAll('='.code.toByte()) while (true) { if (peek == null) {
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 7.2K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/http1/Http1ExchangeCodec.kt
.headers(headersReader.readHeaders()) .trailers { error("trailers not available") } return when { expectContinue && statusLine.code == HTTP_CONTINUE -> { null } statusLine.code == HTTP_CONTINUE -> { state = STATE_READ_RESPONSE_HEADERS responseBuilder } statusLine.code in (102 until 200) -> {
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 16.2K bytes - Viewed (0)