- Sort Score
- Result 10 results
- Languages All
Results 1 - 4 of 4 for countdown (0.06 sec)
-
android/guava-tests/test/com/google/common/cache/CacheLoadingTest.java
cache.getUnchecked(getKey); getFinishedSignal.countDown(); } }.start(); new Thread() { @Override public void run() { cache.refresh(refreshKey); getFinishedSignal.countDown(); } }.start(); // let computation complete letGetFinishSignal.countDown(); getFinishedSignal.await(); checkNothingLogged();
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Fri Oct 18 19:07:49 UTC 2024 - 86.3K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/http2/HttpOverHttp2Test.kt
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Thu Apr 11 22:09:35 UTC 2024 - 75.3K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/EventListenerTest.kt
override fun onFailure( call: Call, e: IOException, ) { completionLatch.countDown() } override fun onResponse( call: Call, response: Response, ) { response.close() completionLatch.countDown() } } call.enqueue(callback) completionLatch.await()
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Sat Jan 20 10:30:28 UTC 2024 - 56.9K bytes - Viewed (2) -
okhttp/src/test/java/okhttp3/internal/http2/Http2ConnectionTest.kt
connection: Http2Connection, settings: Settings, ) { maxConcurrentStreams.set(settings.getMaxConcurrentStreams()) maxConcurrentStreamsUpdated.countDown() } } val connection = connect(peer, IGNORE, listener) connection.withLock { assertThat(connection.peerSettings.getMaxConcurrentStreams()).isEqualTo(10) }
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Sat Apr 20 17:03:43 UTC 2024 - 75.4K bytes - Viewed (0)