- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 63 for readn (0.12 sec)
-
okhttp-tls/src/main/kotlin/okhttp3/tls/internal/der/DerAdapter.kt
* a default value. * * If this does read a value, it starts with the tag and length, and reads an entire value, * including any potential composed values. * * If there's nothing to read and no default value, this will throw an exception. */ fun fromDer(reader: DerReader): T fun fromDer(byteString: ByteString): T {
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 4.2K bytes - Viewed (0) -
okhttp-brotli/src/main/kotlin/okhttp3/brotli/internal/DecompressionBombChecker.kt
private var outputByteCount = 0L fun wrapInput(source: Source): Source { return object : ForwardingSource(source) { override fun read( sink: Buffer, byteCount: Long, ): Long { val result = super.read(sink, byteCount) if (result == -1L) return result inputByteCount += result return result } } }
Plain Text - Registered: Fri Mar 29 11:42:11 GMT 2024 - Last Modified: Mon Jan 29 22:50:20 GMT 2024 - 1.8K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/http2/MockHttp2Peer.kt
require(length < bytesOut.size - lastFrame.start) // Move everything from bytesOut into a new buffer. val fullBuffer = Buffer() bytesOut.read(fullBuffer, bytesOut.size) // Copy back all but what we're truncating. fullBuffer.read(bytesOut, lastFrame.start + length) outFrames.add(OutFrame(lastFrame.sequence, lastFrame.start, true)) return writer }
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Thu Apr 11 22:09:35 GMT 2024 - 8.7K bytes - Viewed (0) -
okhttp-hpacktests/src/test/java/okhttp3/internal/http2/HpackDecodeTestBase.kt
assertSetEquals( "seqno=$testCase.seqno", testCase.headersList, hpackReader.getAndResetHeaderList(), ) } } companion object { /** * Reads all stories in the folders provided, asserts if no story found. */ @JvmStatic protected fun createStories(interopTests: Array<String>): List<Any> { if (interopTests.isEmpty()) return listOf<Any>(Story.MISSING)
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/src/main/kotlin/okhttp3/internal/http2/Huffman.kt
val terminalBitCount: Int /** Construct an internal node. */ constructor() { this.children = arrayOfNulls(256) this.symbol = 0 // Not read. this.terminalBitCount = 0 // Not read. } /** Construct a terminal node. */ constructor(symbol: Int, bits: Int) { this.children = null this.symbol = symbol val b = bits and 0x07
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 8.3K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/Callback.kt
*/ fun onFailure( call: Call, e: IOException, ) /** * Called when the HTTP response was successfully returned by the remote server. The callback may * proceed to read the response body with [Response.body]. The response is still live until its * response body is [closed][ResponseBody]. The recipient of the callback may consume the response * body on another thread. *
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 1.6K bytes - Viewed (0) -
okcurl/src/main/kotlin/okhttp3/curl/Main.kt
val connectTimeout: Int by option( "--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)",
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 5.7K bytes - Viewed (1) -
okhttp-idna-mapping-table/src/main/kotlin/okhttp3/internal/idn/SimpleIdnaMappingTable.kt
private fun BufferedSource.skipRestOfLine() { when (val newline = indexOf('\n'.code.toByte())) { -1L -> skip(buffer.size) // Exhaust this source. else -> skip(newline + 1) } } /** * Reads lines from `IdnaMappingTable.txt`. * * Comment lines are either blank or start with a `#` character. Lines may also end with a comment. * All comments are ignored. *
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/ServerTruncatesRequestTest.kt
expectedEvents += "ConnectionAcquired" expectedEvents += "RequestHeadersStart" expectedEvents += "RequestHeadersEnd" expectedEvents += "RequestBodyStart" // ... but we can read the response even after writing the request fails. expectedEvents += "RequestFailed" expectedEvents += "ResponseHeadersStart" expectedEvents += "ResponseHeadersEnd" expectedEvents += "ResponseBodyStart"
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 9.5K bytes - Viewed (0) -
docs/contribute/concurrency.md
Framing rules make it impractical to implement http/2 correctly on a single blocking thread. The flow-control features introduce feedback between reads and writes, requiring writes to acknowledge reads and reads to throttle writes. In OkHttp we expose a blocking API over a framed protocol. This document explains the code and policy that makes that work. ### Threads #### Application's calling thread
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sun Feb 06 16:35:36 GMT 2022 - 7K bytes - Viewed (0)