- Sort Score
- Result 10 results
- Languages All
Results 1 - 7 of 7 for Sleeps (0.04 sec)
-
okhttp/src/jvmTest/kotlin/okhttp3/EventListenerTest.kt
override fun writeTo(sink: BufferedSink) { try { var i = 0 while (i < contentLength()) { sink.write(chunk!!) sink.flush() Thread.sleep(100) i += chunk.size } } catch (e: IOException) { ioe = e } catch (e: InterruptedException) { throw RuntimeException(e) } } }
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Fri Jun 20 11:46:46 UTC 2025 - 60.4K bytes - Viewed (0) -
okhttp/src/jvmTest/kotlin/okhttp3/internal/http2/HttpOverHttp2Test.kt
private fun waitForConnectionShutdown(connection: RealConnection?) { if (connection!!.isHealthy(false)) { Thread.sleep(100L) } if (connection.isHealthy(false)) { Thread.sleep(2000L) } if (connection.isHealthy(false)) { throw TimeoutException("connection didn't shutdown within timeout") } } /**
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Fri Jun 20 11:46:46 UTC 2025 - 73.4K bytes - Viewed (0) -
okhttp/src/commonJvmAndroid/kotlin/okhttp3/OkHttpClient.kt
} /** * Sets the interval between HTTP/2 and web socket pings initiated by this client. Use this to * automatically send ping frames until either the connection fails or it is closed. This keeps * the connection alive and may detect connectivity failures. * * If the server does not respond to each ping with a pong within `interval`, this client will
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Mon May 05 16:01:00 UTC 2025 - 51.7K bytes - Viewed (0) -
guava-tests/test/com/google/common/cache/CacheLoadingTest.java
Object oldValue = ref.get(); if (oldValue == null) { expectedComputations++; } ref = new WeakReference<>(cache.getUnchecked(1)); oldValue = null; Thread.sleep(i); System.gc(); } assertEquals(expectedComputations, countingLoader.getCount()); for (int i = 0; i < iterations; i++) { // The entry should get garbage collected and recomputed.
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Mon Aug 11 19:31:30 UTC 2025 - 85.7K bytes - Viewed (0) -
docs/changelogs/changelog_3x.md
`HandshakeCertificates` holds the TLS certificates required for a TLS handshake. On the server it keeps your `HeldCertificate` and its chain. On the client it keeps the root certificates that are trusted to sign a server's certificate chain. `HandshakeCertificates` also works with mutual TLS where these roles are reversed.
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Sun Feb 06 14:55:54 UTC 2022 - 50.8K bytes - Viewed (0) -
android/guava/src/com/google/common/collect/Iterators.java
* is the only one in use, but if we encounter nested concatenations, we start a deque of * meta-iterators rather than letting the nesting get arbitrarily deep. This keeps each * operation O(1). */ private @Nullable Iterator<? extends Iterator<? extends T>> topMetaIterator; // Only becomes nonnull if we encounter nested concatenations.
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Thu Aug 07 16:05:33 UTC 2025 - 50.5K bytes - Viewed (0) -
okhttp/src/jvmTest/kotlin/okhttp3/internal/http2/Http2ConnectionTest.kt
assertThat(connection.isHealthy(System.nanoTime())).isTrue() // But if the ping doesn't arrive, the connection goes unhealthy. Thread.sleep(TimeUnit.NANOSECONDS.toMillis(Http2Connection.DEGRADED_PONG_TIMEOUT_NS.toLong())) assertThat(connection.isHealthy(System.nanoTime())).isFalse() // When a pong does arrive, the connection becomes healthy again.
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Thu Jul 31 04:18:40 UTC 2025 - 75.5K bytes - Viewed (0)