- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 31 for hasNext (0.16 sec)
-
docs/features/caching.md
Removing individual items can be done using the urls iterator. This would be typical after a user initiates a force refresh by a pull to refresh type action. ```java val urlIterator = cache.urls() while (urlIterator.hasNext()) { if (urlIterator.next().startsWith("https://www.google.com/")) { urlIterator.remove() } } ``` ### Troubleshooting 1. Valid cacheable responses are not being cached
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sun Feb 06 02:19:09 GMT 2022 - 3.1K 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/test/java/okhttp3/internal/cache/DiskLruCacheTest.kt
set("b", "b1", "b2") set("c", "c1", "c2") val iterator = cache.snapshots() assertThat(iterator.hasNext()).isTrue() iterator.next().use { assertThat(it.key()).isEqualTo("a") it.assertValue(0, "a1") it.assertValue(1, "a2") } assertThat(iterator.hasNext()).isTrue() iterator.next().use { assertThat(it.key()).isEqualTo("b") it.assertValue(0, "b1")
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/main/kotlin/okhttp3/internal/tls/BasicCertificateChainCleaner.kt
} // Search for the certificate in the chain that signed this certificate. This is typically // the next element in the chain, but it could be any element. val i = queue.iterator() while (i.hasNext()) { val signingCert = i.next() as X509Certificate if (verifySignature(toVerify, signingCert, result.size - 1)) { i.remove() result.add(signingCert) continue@followIssuerChain
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 4.8K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/connection/RoutePlanner.kt
* * @param failedConnection an optional connection that was resulted in a failure. If the failure * is recoverable, the connection's route may be recovered for the retry. */ fun hasNext(failedConnection: RealConnection? = null): Boolean /** * Returns true if the host and port are unchanged from when this was created. This is used to
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Wed Dec 20 23:27:07 GMT 2023 - 4.2K bytes - Viewed (0) -
okhttp-tls/src/main/kotlin/okhttp3/tls/internal/der/Adapters.kt
while (list.size < members.size) { val member = members[list.size] list += member.fromDer(reader) } if (reader.hasNext()) { throw ProtocolException("unexpected ${reader.peekHeader()} at $reader") } return@withTypeHint construct(list) } } override fun encode(
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 15K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/FakeRoutePlanner.kt
taskFaker.yield() } val planningThrowable = result.planningThrowable if (planningThrowable != null) throw planningThrowable return result } override fun hasNext(failedConnection: RealConnection?): Boolean { return deferredPlans.isNotEmpty() || nextPlanIndex < plans.size || autoGeneratePlans } override fun sameHostAndPort(url: HttpUrl): Boolean {
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Wed Apr 24 04:40:49 GMT 2024 - 6.2K bytes - Viewed (0) -
okhttp-tls/src/main/kotlin/okhttp3/tls/internal/der/DerReader.kt
private var constructed = false private var peekedHeader: DerHeader? = null private val bytesLeft: Long get() = if (limit == -1L) -1L else (limit - byteCount) fun hasNext(): Boolean = peekHeader() != null /** * Returns the next header to process unless this scope is exhausted. * * This returns null if: * * * The stream is exhausted.
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 10.5K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/cache/DiskLruCache.kt
private var removeSnapshot: Snapshot? = null override fun hasNext(): Boolean { if (nextSnapshot != null) return true synchronized(this@DiskLruCache) { // If the cache is closed, truncate the iterator. if (closed) return false while (delegate.hasNext()) { nextSnapshot = delegate.next()?.snapshot() ?: continue return true
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-tls/src/main/kotlin/okhttp3/tls/internal/der/DerAdapter.kt
for (v in value) { toDer(writer, v) } } override fun decode(reader: DerReader): List<T> { val result = mutableListOf<T>() while (reader.hasNext()) { result += fromDer(reader) } return result } } return BasicDerAdapter(name, tagClass, tag, codec) }
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)