- Sort Score
- Result 10 results
- Languages All
Results 51 - 60 of 79 for exhaust (0.03 sec)
-
src/test/java/jcifs/smb/ShareEnumIteratorTest.java
// End of iteration behavior assertFalse(it.hasNext(), "No more elements expected"); assertNull(it.next(), "next() returns null when exhausted in this implementation"); } @Test @DisplayName("With filter: only accepted entries are returned and filter is invoked per entry")
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Thu Aug 14 05:31:44 UTC 2025 - 8.1K bytes - Viewed (0) -
okhttp/src/commonJvmAndroid/kotlin/okhttp3/MultipartReader.kt
} /** * Returns a value in [0..maxByteCount] with the number of bytes that can be read from [source] * in the current part. If this returns 0 the current part is exhausted; otherwise it has at * least one byte left to read. */ private fun currentPartBytesRemaining(maxByteCount: Long): Long { val toIndex = minOf(source.buffer.size, maxByteCount) + 1L
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Wed May 28 02:11:14 UTC 2025 - 7.3K bytes - Viewed (0) -
okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/publicsuffix/PublicSuffixDatabase.kt
currentLabelByteIndex++ if (publicSuffixByteIndex == publicSuffixLength) break if (labels[currentLabelIndex].size == currentLabelByteIndex) { // We've exhausted our current label. Either there are more labels to compare, in which // case we expect a dot as the next character. Otherwise, we've checked all our labels. if (currentLabelIndex == labels.size - 1) {
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Mon Jul 28 07:33:49 UTC 2025 - 8.5K bytes - Viewed (0) -
okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/ws/WebSocketReader.kt
maskCursor.seek(messageFrameBuffer.size - frameLength) toggleMask(maskCursor, maskKey!!) maskCursor.close() } } if (isFinalFrame) break // We are exhausted and have no continuations. readUntilNonControlFrame() if (opcode != OPCODE_CONTINUATION) { throw ProtocolException("Expected continuation opcode. Got: ${opcode.toHexString()}") } }
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Tue Jul 29 22:04:11 UTC 2025 - 9.9K bytes - Viewed (0) -
okhttp-testing-support/src/main/kotlin/okhttp3/internal/concurrent/TaskFaker.kt
try { while (currentTask != self) { taskRunner.wait() } } finally { serialTaskQueue.remove(yieldCompleteTask) } // If we're yielding until we're exhausted and a task run, keep going until a task doesn't run. if (strategy == ResumePriority.AfterOtherTasks && otherTasksStarted) { return yieldUntil(strategy, condition) } }
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Wed May 28 23:28:25 UTC 2025 - 11.9K bytes - Viewed (0) -
okhttp-tls/src/main/kotlin/okhttp3/tls/internal/der/CertificateAdapters.kt
override fun fromDer(reader: DerReader): Long { val peekHeader = reader.peekHeader() ?: throw ProtocolException("expected time but was exhausted at $reader") return when { peekHeader.tagClass == Adapters.UTC_TIME.tagClass && peekHeader.tag == Adapters.UTC_TIME.tag -> { Adapters.UTC_TIME.fromDer(reader) }
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Wed Mar 19 19:25:20 UTC 2025 - 13.6K bytes - Viewed (0) -
okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/-UtilCommon.kt
internal inline fun ignoreIoExceptions(block: () -> Unit) { try { block() } catch (_: IOException) { } } internal fun Buffer.skipAll(b: Byte): Int { var count = 0 while (!exhausted() && this[0] == b) { count++ readByte() } return count } /** * Returns the index of the next non-whitespace character in this. Result is undefined if input
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Mon May 05 16:01:00 UTC 2025 - 10.1K bytes - Viewed (0) -
okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/connection/RealRoutePlanner.kt
) routeSelector = newRouteSelector } // List available IP addresses for the current proxy. This may block in Dns.lookup(). if (!newRouteSelector.hasNext()) throw IOException("exhausted all routes") val newRouteSelection = newRouteSelector.next() routeSelection = newRouteSelection if (isCanceled()) throw IOException("Canceled")
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Wed May 28 23:28:25 UTC 2025 - 12K bytes - Viewed (0) -
okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/-HostnamesCommon.kt
return result } internal fun idnToAscii(host: String): String? { val bufferA = Buffer().writeUtf8(host) val bufferB = Buffer() // 1. Map, from bufferA to bufferB. while (!bufferA.exhausted()) { val codePoint = bufferA.readUtf8CodePoint() if (!IDNA_MAPPING_TABLE.map(codePoint, bufferB)) return null } // 2. Normalize, from bufferB to bufferA.
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Wed Mar 19 19:25:20 UTC 2025 - 11.2K bytes - Viewed (0) -
okhttp/src/jvmTest/kotlin/okhttp3/TrailersTest.kt
) val call = client.newCall(Request(server.url("/"))) call.execute().use { response -> assertThat(response.trailers()).isEqualTo(headersOf("t1", "v2")) assertThat(response.body.source().exhausted()).isTrue() } } @Test @Disabled fun trailersAndCacheHttp1() { trailersAndCache(Protocol.HTTP_1_1) } @Test @Disabled fun trailersAndCacheHttp2() {
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Mon Jul 07 18:57:05 UTC 2025 - 18K bytes - Viewed (0)