- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 112 for whale (0.18 sec)
-
okhttp/src/main/kotlin/okhttp3/internal/cache2/Relay.kt
* block until that read completes. It is possible to time out while waiting for that. */ @Throws(IOException::class) override fun read( sink: Buffer, byteCount: Long, ): Long { check(fileOperator != null) val source: Int = synchronized(this@Relay) { // We need new data from upstream. while (true) { val upstreamPos = ******@****.***amPos
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/-HostnamesCommon.kt
var b = addressOffset var i = pos while (i < limit) { if (b == address.size) return false // Too many groups. // Read a delimiter. if (b != addressOffset) { if (input[i] != '.') return false // Wrong delimiter. i++ } // Read 1 or more decimal digits for a value in 0..255. var value = 0 val groupOffset = i while (i < limit) { val c = input[i]
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 11.2K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/idn/Punycode.kt
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Wed Apr 03 03:04:50 GMT 2024 - 8.5K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/http2/Huffman.kt
val code = CODES[symbol] val codeBitCount = CODE_BIT_COUNTS[symbol].toInt() accumulator = (accumulator shl codeBitCount) or code.toLong() accumulatorBitCount += codeBitCount while (accumulatorBitCount >= 8) { accumulatorBitCount -= 8 sink.writeByte((accumulator shr accumulatorBitCount).toInt()) } } if (accumulatorBitCount > 0) {
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-idna-mapping-table/src/main/kotlin/okhttp3/internal/idn/SimpleIdnaMappingTable.kt
internal const val TYPE_DISALLOWED_STD3_VALID = 3 internal const val TYPE_IGNORED = 4 internal const val TYPE_MAPPED = 5 internal const val TYPE_VALID = 6 private fun BufferedSource.skipWhitespace() { while (!exhausted()) { if (buffer[0] != ' '.code.toByte()) return skip(1L) } } private fun BufferedSource.skipRestOfLine() { when (val newline = indexOf('\n'.code.toByte())) {
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-sse/src/main/kotlin/okhttp3/sse/internal/ServerSentEventReader.kt
* data section was empty. Any number of calls to [Callback.onRetryChange] may occur while * processing an event. * * @return false when EOF is reached */ @Throws(IOException::class) fun processNextEvent(): Boolean { var id = lastId var type: String? = null val data = Buffer() while (true) { when (source.select(options)) { in 0..2 -> {
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 4.3K bytes - Viewed (0) -
okhttp-testing-support/src/main/kotlin/okhttp3/RecordingConnectionListener.kt
* and returns it. */ fun <T : ConnectionEvent> removeUpToEvent(eventClass: Class<T>): T { val fullEventSequence = eventSequence.toList() try { while (true) { val event = takeEvent() if (eventClass.isInstance(event)) { return eventClass.cast(event) } } } catch (e: NoSuchElementException) {
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/ws/WebSocketWriterTest.kt
assertData("8232") assertData(payload) } @Test fun serverMessageLengthShort() { // Create a payload which will overflow the normal payload byte size. val payload = Buffer() while (payload.completeSegmentByteCount() <= PAYLOAD_BYTE_MAX) { payload.writeByte('0'.code) } serverWriter.writeMessageFrame(OPCODE_BINARY, payload.snapshot())
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/src/test/java/okhttp3/internal/http/ExternalHttp2Example.kt
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 1.4K bytes - Viewed (0) -
okhttp-java-net-cookiejar/src/main/kotlin/okhttp3/java/net/cookiejar/JavaNetCookieJar.kt
private fun decodeHeaderAsJavaNetCookies( url: HttpUrl, header: String, ): List<Cookie> { val result = mutableListOf<Cookie>() var pos = 0 val limit = header.length var pairEnd: Int while (pos < limit) { pairEnd = header.delimiterOffset(";,", pos, limit) val equalsSign = header.delimiterOffset('=', pos, pairEnd) val name = header.trimSubstring(pos, equalsSign) if (name.startsWith("$")) {
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)