- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 29 for Breiding (0.27 sec)
-
okhttp/src/main/kotlin/okhttp3/internal/cache2/Relay.kt
var complete = (upstream == null) /** The most recently read bytes from [upstream]. This is a suffix of [file]. Guarded by this. */ val buffer = Buffer() /** * Reference count of the number of active sources reading this stream. When decremented to 0 * resources are released and all following calls to [.newSource] return null. Guarded by this. */ var sourceCount = 0 val isClosed: Boolean get() = file == null
Plain Text - Registered: Fri Apr 26 11:42:10 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 11.8K bytes - Viewed (0) -
okcurl/src/main/kotlin/okhttp3/curl/Main.kt
"--connect-timeout", help = "Maximum time allowed for connection (seconds)", ).int().default(DEFAULT_TIMEOUT) val readTimeout: Int by option("--read-timeout", help = "Maximum time allowed for reading data (seconds)").int().default(DEFAULT_TIMEOUT) val callTimeout: Int by option( "--call-timeout", help = "Maximum time allowed for the entire call (seconds)", ).int().default(DEFAULT_TIMEOUT)
Plain Text - Registered: Fri Apr 26 11:42:10 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 5.7K bytes - Viewed (1) -
okhttp/src/test/java/okhttp3/URLConnectionTest.kt
val response = call.execute() val inputStream = response.body.byteStream() assertThat(inputStream.read().toChar()).isEqualTo('A') call.cancel() assertFailsWith<IOException> { // Reading 'B' may succeed if it's buffered. inputStream.read() // But 'C' shouldn't be buffered (the response is throttled) and this should fail. inputStream.read() } inputStream.close()
Plain Text - Registered: Fri Apr 26 11:42:10 GMT 2024 - Last Modified: Sat Jan 20 10:30:28 GMT 2024 - 131.7K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/WebSocketListener.kt
*/ open fun onClosed( webSocket: WebSocket, code: Int, reason: String, ) { } /** * Invoked when a web socket has been closed due to an error reading from or writing to the * network. Both outgoing and incoming messages may have been lost. No further calls to this * listener will be made. */ open fun onFailure( webSocket: WebSocket, t: Throwable,
Plain Text - Registered: Fri Apr 26 11:42:10 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 2K bytes - Viewed (0) -
CHANGELOG.md
* Fix: Don't leak file handles when a cache disk write fails. * Fix: Don't hang when the public suffix database cannot be loaded. We had a bug where a failure reading the public suffix database would cause subsequent reads to hang when they should have crashed. * Fix: Avoid `InetAddress.getCanonicalHostName()` in MockWebServer. This avoids problems if the
Plain Text - Registered: Fri Apr 26 11:42:10 GMT 2024 - Last Modified: Thu Apr 18 01:31:39 GMT 2024 - 21.4K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/OkHttpClient.kt
* must be between 1 and [Integer.MAX_VALUE] when converted to milliseconds. * * The call timeout spans the entire call: resolving DNS, connecting, writing the request body, * server processing, and reading the response body. If the call requires redirects or retries * all must complete within one timeout period. * * The default value is 0 which imposes no timeout. */ fun callTimeout(
Plain Text - Registered: Fri Apr 26 11:42:10 GMT 2024 - Last Modified: Sat Apr 06 04:21:33 GMT 2024 - 52K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/cache/DiskLruCacheTest.kt
val editor = cache.edit("k1")!! assertThat(cache["k1"]).isNull() editor.commit() } @ParameterizedTest @ArgumentsSource(FileSystemParamProvider::class) fun `Windows cannot write while reading`(parameters: Pair<FileSystem, Boolean>) { setUp(parameters.first, parameters.second) Assumptions.assumeTrue(windows) set("k1", "a", "a") val snapshot = cache["k1"]!!
Plain Text - Registered: Fri Apr 26 11:42:10 GMT 2024 - Last Modified: Mon Apr 15 14:55:09 GMT 2024 - 75.8K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/http2/Http2Connection.kt
} private fun failConnection(e: IOException?) { close(ErrorCode.PROTOCOL_ERROR, ErrorCode.PROTOCOL_ERROR, e) } /** * Sends any initial frames and starts reading frames from the remote peer. This should be called * after [Builder.build] for all new connections. * * @param sendConnectionPreface true to send connection preface frames. This should always be true
Plain Text - Registered: Fri Apr 26 11:42:10 GMT 2024 - Last Modified: Sat Apr 20 17:03:43 GMT 2024 - 32.6K bytes - Viewed (0) -
okhttp-hpacktests/src/test/java/okhttp3/internal/http2/hpackjson/HpackJsonUtil.kt
import okio.ByteString import okio.ByteString.Companion.decodeHex import okio.FileSystem import okio.Path import okio.Path.Companion.toOkioPath import okio.buffer import okio.source /** * Utilities for reading HPACK tests. */ object HpackJsonUtil { @Suppress("unused") private val MOSHI = Moshi.Builder() .add( object : Any() {
Plain Text - Registered: Fri Apr 26 11:42:10 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 3.3K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/Call.kt
*/ fun isExecuted(): Boolean fun isCanceled(): Boolean /** * Returns a timeout that spans the entire call: resolving DNS, connecting, writing the request * body, server processing, and reading the response body. If the call requires redirects or * retries all must complete within one timeout period. * * Configure the client's default timeout with [OkHttpClient.Builder.callTimeout]. */
Plain Text - Registered: Fri Apr 26 11:42:10 GMT 2024 - Last Modified: Wed Dec 20 23:27:07 GMT 2023 - 3.6K bytes - Viewed (0)