- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 45 for Ensure (0.17 sec)
-
okhttp/src/test/java/okhttp3/internal/publicsuffix/PublicSuffixListGenerator.kt
withContext(Dispatchers.IO) { fileSystem.sink(outputFile).gzip().buffer().use { sink -> importResults.writeOut(sink) } } /** * These assertions ensure the [PublicSuffixDatabase] remains correct. The specification is * very flexible regarding wildcard rules, but this flexibility is not something currently used
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/http/DateFormatting.kt
/** The last four-digit year: "Fri, 31 Dec 9999 23:59:59 GMT". */ internal const val MAX_DATE = 253402300799999L /** * Most websites serve cookies in the blessed format. Eagerly create the parser to ensure such * cookies are on the fast path. */ private val STANDARD_DATE_FORMAT = object : ThreadLocal<DateFormat>() { override fun initialValue(): DateFormat { // Date format specified by RFC 7231 section 7.1.1.1.
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 4.1K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/URLConnectionTest.kt
) // Send a separate request which will trigger a GOAWAY frame on the healthy connection. val response = getResponse(newRequest("/")) assertContent("abc", response) // Ensure the GOAWAY frame has time to be read and processed. Thread.sleep(500) assertContent( "def", getResponse( Request( url = server.url("/"),
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sat Jan 20 10:30:28 GMT 2024 - 131.7K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/Call.kt
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Wed Dec 20 23:27:07 GMT 2023 - 3.6K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/http/CallServerInterceptor.kt
code = response.code } exchange.responseHeadersEnd(response) response = if (forWebSocket && code == 101) { // Connection is upgrading, but we need to ensure interceptors see a non-null response body. response.stripBody() } else { response.newBuilder() .body(exchange.openResponseBody(response)) .build() }
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 6.3K bytes - Viewed (1) -
okhttp/src/main/kotlin/okhttp3/internal/ws/MessageInflater.kt
deflatedBytes.writeInt(OCTETS_TO_ADD_BEFORE_INFLATION) val totalBytesToRead = inflater.bytesRead + deflatedBytes.size // We cannot read all, as the source does not close. // Instead, we ensure that all bytes from source have been processed by inflater. do { inflaterSource.readOrInflate(buffer, Long.MAX_VALUE) } while (inflater.bytesRead < totalBytesToRead && !inflater.finished()) }
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 1.8K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/ws/WebSocketWriterTest.kt
payload.writeByte('0'.code) } serverWriter.writeMessageFrame(OPCODE_BINARY, payload.snapshot()) // Write directly to the unbuffered sink. This ensures it will become single frame. assertData("827e") // 'e' == 4-byte follow-up length. assertData(format("%04X", payload.completeSegmentByteCount())) assertData(payload.readByteString()) }
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) -
okhttp-android/build.gradle.kts
id("com.vanniktech.maven.publish.base") id("binary-compatibility-validator") } android { compileSdk = 34 namespace = "okhttp.android" defaultConfig { minSdk = 21 // Make sure to use the AndroidJUnitRunner (or a sub-class) in order to hook in the JUnit 5 Test Builder testInstrumentationRunner = "androidx.test.runner.AndroidJUnitRunner" buildFeatures { buildConfig = false }
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Apr 01 11:07:32 GMT 2024 - 2K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/platform/android/AndroidLog.kt
if (Log.isLoggable(tag, logLevel)) { var logMessage = message if (t != null) logMessage = logMessage + '\n'.toString() + Log.getStackTraceString(t) // Split by line, then ensure each line can fit into Log's maximum length. var i = 0 val length = logMessage.length while (i < length) { var newline = logMessage.indexOf('\n', i)
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 3.9K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/osgi/OsgiTest.kt
private lateinit var workspaceDir: Path @BeforeEach fun setUp() { testResourceDir = "./build/resources/test/okhttp3/osgi".toPath() workspaceDir = testResourceDir / "workspace" // Ensure we start from scratch. fileSystem.deleteRecursively(workspaceDir) fileSystem.createDirectories(workspaceDir) } /**
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 4.9K bytes - Viewed (0)