- Sort Score
- Result 10 results
- Languages All
Results 31 - 40 of 55 for clean (0.14 sec)
-
okhttp/src/main/kotlin/okhttp3/internal/-UtilJvm.kt
} timeout().deadlineNanoTime(nowNs + minOf(originalDurationNs, timeUnit.toNanos(duration.toLong()))) return try { val skipBuffer = Buffer() while (read(skipBuffer, 8192) != -1L) { skipBuffer.clear() } true // Success! The source has been exhausted. } catch (_: InterruptedIOException) { false // We ran out of time before exhausting the source. } finally {
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Tue Jan 09 12:33:05 GMT 2024 - 10.5K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/ws/WebSocketReaderTest.kt
assertFailsWith<ProtocolException> { clientReader.processNextFrame() }.also { expected -> assertThat(expected.message).isEqualTo("Unexpected rsv2 flag") } data.clear() data.write("9a00".decodeHex()) // Empty pong, flag 3 set. assertFailsWith<ProtocolException> { clientReader.processNextFrame() }.also { expected ->
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 14.4K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/-UtilCommon.kt
internal fun FileSystem.deleteIfExists(path: Path) { try { delete(path) } catch (fnfe: FileNotFoundException) { return } } /** Tolerant delete, try to clear as many files as possible even after a failure. */ internal fun FileSystem.deleteContents(directory: Path) { var exception: IOException? = null val files = try { list(directory)
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 11K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/HttpUrl.kt
} val c = input[pos] if (c == '/' || c == '\\') { // Absolute path: reset to the default "/". encodedPathSegments.clear() encodedPathSegments.add("") pos++ } else { // Relative path: clear everything after the last '/'. encodedPathSegments[encodedPathSegments.size - 1] = "" } // Read path segments. var i = pos
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Tue Jan 09 12:33:05 GMT 2024 - 63.5K bytes - Viewed (1) -
okhttp/src/main/kotlin/okhttp3/MultipartBody.kt
} // We can't measure the body's size without the sizes of its components. val contentLength = body.contentLength() if (contentLength == -1L && countBytes) { byteCountBuffer!!.clear() return -1L } sink.write(CRLF) if (countBytes) { byteCount += contentLength } else { body.writeTo(sink) } sink.write(CRLF)
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 10.9K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/FormBody.kt
buffer.writeUtf8(encodedNames[i]) buffer.writeByte('='.code) buffer.writeUtf8(encodedValues[i]) } if (countBytes) { byteCount = buffer.size buffer.clear() } return byteCount } class Builder @JvmOverloads constructor(private val charset: Charset? = null) { private val names = mutableListOf<String>()
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Tue Jan 09 12:33:05 GMT 2024 - 4.3K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/http/RetryAndFollowUpInterceptor.kt
throw e.withSuppressed(recoveredFailures) } else { recoveredFailures += e } newRoutePlanner = false continue } // Clear out downstream interceptor's additional request headers, cookies, etc. response = response.newBuilder() .request(request) .priorResponse(priorResponse?.stripBody())
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Apr 15 13:24:48 GMT 2024 - 12.1K bytes - Viewed (4) -
CHANGELOG.md
possible to implement decorators for cache encryption or compression. * New: `Cookie.newBuilder()` to build upon an existing cookie. * New: Use TLSv1.3 when running on JDK 8u261 or newer. * New: `QueueDispatcher.clear()` may be used to reset a MockWebServer instance. * New: `FileDescriptor.toRequestBody()` may be particularly useful for users of Android's Storage Access Framework. * Upgrade: [Kotlin 1.5.31][kotlin_1_5_31].
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Thu Apr 18 01:31:39 GMT 2024 - 21.4K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/http/ThreadInterruptTest.kt
return socket } }, ) .build() } @AfterEach fun tearDown() { Thread.interrupted() // Clear interrupted state. } @Test fun interruptWritingRequestBody() { server.enqueue(MockResponse()) server.start() val call = client.newCall( Request.Builder()
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 4.6K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/http2/Http2Stream.kt
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sat Apr 20 17:03:43 GMT 2024 - 23.2K bytes - Viewed (1)