- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 36 for iterator (0.26 sec)
-
okhttp/src/test/java/okhttp3/internal/http2/MockHttp2Peer.kt
} } val outputStream = socket.getOutputStream() val inputStream = socket.getInputStream() val reader = Http2Reader(inputStream.source().buffer(), client) val outFramesIterator: Iterator<OutFrame> = outFrames.iterator() val outBytes = bytesOut.readByteArray() var nextOutFrame: OutFrame? = null for (i in 0 until frameCount) { if (nextOutFrame == null && outFramesIterator.hasNext()) {
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/src/main/kotlin/okhttp3/Cache.kt
cache.evictAll() } /** * Returns an iterator over the URLs in this cache. This iterator doesn't throw * `ConcurrentModificationException`, but if new responses are added while iterating, their URLs * will not be returned. If existing responses are evicted during iteration, they will be absent * (unless they were already returned). *
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Wed Apr 10 19:46:48 GMT 2024 - 26.8K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/Headers.kt
for (i in 0 until namesAndValues.size) { result += namesAndValues[i].length.toLong() } return result } override operator fun iterator(): Iterator<Pair<String, String>> = commonIterator() fun newBuilder(): Builder = commonNewBuilder() /** * Returns true if `other` is a `Headers` object with the same headers, with the same casing, in
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 11.5K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/RecordingCallback.kt
*/ @Synchronized fun await(url: HttpUrl): RecordedResponse { val timeoutMillis = TimeUnit.NANOSECONDS.toMillis(System.nanoTime()) + TIMEOUT_MILLIS while (true) { val i = responses.iterator() while (i.hasNext()) { val recordedResponse = i.next() if (recordedResponse.request.url.equals(url)) { i.remove() return recordedResponse } }
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 2.1K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/-HeadersCommon.kt
if (result == null) result = ArrayList(2) result.add(value(i)) } } return result?.toList().orEmpty() } internal fun Headers.commonIterator(): Iterator<Pair<String, String>> { return Array(size) { name(it) to value(it) }.iterator() } internal fun Headers.commonNewBuilder(): Headers.Builder { val result = Headers.Builder() result.namesAndValues += namesAndValues return result }
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 5.9K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/cache/DiskLruCacheTest.kt
@ParameterizedTest @ArgumentsSource(FileSystemParamProvider::class) fun iterator(parameters: Pair<FileSystem, Boolean>) { setUp(parameters.first, parameters.second) set("a", "a1", "a2") set("b", "b1", "b2") set("c", "c1", "c2") val iterator = cache.snapshots() assertThat(iterator.hasNext()).isTrue() iterator.next().use { assertThat(it.key()).isEqualTo("a")
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Apr 15 14:55:09 GMT 2024 - 75.8K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/RecordingExecutor.kt
fun assertJobs(vararg expectedUrls: String) { val actualUrls = calls.map { it.request.url.toString() } assertThat(actualUrls).containsExactly(*expectedUrls) } fun finishJob(url: String) { val i = calls.iterator() while (i.hasNext()) { val call = i.next() if (call.request.url.toString() == url) { i.remove() dispatcherTest.dispatcher.finishedAccessor(call) return } }
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 2.1K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/cache/DiskLruCache.kt
* entries will not be returned by the iterator. If existing entries are removed during iteration, * they will be absent (unless they were already returned). * * If there are I/O problems during iteration, this iterator fails silently. For example, if the * hosting filesystem becomes unreachable, the iterator will omit elements rather than throwing * exceptions. *
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 34.7K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/-UtilCommon.kt
val commonEmptyResponse: ResponseBody = EMPTY_BYTE_ARRAY.toResponseBody() internal fun <T> interleave( a: Iterable<T>, b: Iterable<T>, ): List<T> { val ia = a.iterator() val ib = b.iterator() return buildList { while (ia.hasNext() || ib.hasNext()) { if (ia.hasNext()) { add(ia.next()) } if (ib.hasNext()) { add(ib.next()) }
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-testing-support/src/main/kotlin/okhttp3/FakeDns.kt
private val requestedHosts: MutableList<String> = mutableListOf() private var nextAddress = 0xff000064L // 255.0.0.100 in IPv4; ::ff00:64 in IPv6. /** Sets the results for `hostname`. */ operator fun set( hostname: String, addresses: List<InetAddress>, ): FakeDns { hostAddresses[hostname] = addresses return this } /** Clears the results for `hostname`. */
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 2.6K bytes - Viewed (0)