- Sort Score
- Result 10 results
- Languages All
Results 31 - 40 of 79 for countdown (0.05 sec)
-
okhttp/src/test/java/okhttp3/DispatcherTest.kt
val waiting = CountDownLatch(1) client = client.newBuilder() .addInterceptor( Interceptor { chain: Interceptor.Chain? -> try { ready.countDown() waiting.await() } catch (e: InterruptedException) { throw AssertionError() } throw IOException() }, ) .build()
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Fri Apr 05 03:30:42 UTC 2024 - 12.7K bytes - Viewed (0) -
guava-testlib/src/com/google/common/testing/GcFinalization.java
* * <p>Here's an example that tests a {@code finalize} method: * * <pre>{@code * final CountDownLatch latch = new CountDownLatch(1); * Object x = new MyClass() { * ... * protected void finalize() { latch.countDown(); ... } * }; * x = null; // Hint to the JIT that x is stack-unreachable * GcFinalization.await(latch); * }</pre> * * <p>Here's an example that uses a user-defined finalization predicate: * * <pre>{@code
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Sat Oct 19 00:26:48 UTC 2024 - 11.6K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/suggest/concurrent/Deferred.java
if (executeCallbacks.size() > 0) { try { executeCallbacks.stream().forEach(callback -> callback.accept(response)); } catch (final Exception ignore) {} } latch.countDown(); } public void reject(final Throwable t) { final ArrayList<Consumer<Throwable>> executeCallbacks; synchronized (Deferred.this) { if (response != null || error != null) {
Registered: Fri Nov 08 09:08:12 UTC 2024 - Last Modified: Thu Feb 22 01:36:54 UTC 2024 - 5.4K bytes - Viewed (0) -
okhttp-dnsoverhttps/src/main/kotlin/okhttp3/dnsoverhttps/DnsOverHttps.kt
synchronized(failures) { failures.add(e) } latch.countDown() } override fun onResponse( call: Call, response: Response, ) { processResponse(response, hostname, responses, failures) latch.countDown() } }, ) } try { latch.await()
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Thu Oct 31 09:27:31 UTC 2024 - 9.8K bytes - Viewed (0) -
mockwebserver/src/test/java/mockwebserver3/CustomDispatcherTest.kt
endsFirst.join() // First response is still waiting. assertThat(firstResponseCode.get()).isEqualTo(0) // Second response is done. assertThat(secondResponseCode.get()).isEqualTo(200) latch.countDown() startsFirst.join() // And now it's done! assertThat(firstResponseCode.get()).isEqualTo(200) // (Still done). assertThat(secondResponseCode.get()).isEqualTo(200) }
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Mon Jan 08 01:13:22 UTC 2024 - 3.3K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/ListenableFutureTester.java
this.latch = new CountDownLatch(1); } public void setUp() { future.addListener( new Runnable() { @Override public void run() { latch.countDown(); } }, exec); assertEquals(1, latch.getCount()); assertFalse(future.isDone()); assertFalse(future.isCancelled()); } public void tearDown() {
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Fri Oct 18 22:10:29 UTC 2024 - 3.3K bytes - Viewed (0) -
okhttp-android/src/androidTest/kotlin/okhttp3/android/AndroidAsyncDnsTest.kt
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Mon Jan 08 01:13:22 UTC 2024 - 5.7K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/FuturesTransformAsyncTest.java
outputFuture.set(RESULT_DATA); break; case SLOW_OUTPUT_VALID_INPUT_DATA: break; // do nothing to the result case SLOW_FUNC_VALID_INPUT_DATA: funcIsWaitingLatch.countDown(); awaitUninterruptibly(funcCompletionLatch); break; case EXCEPTION_DATA: throw EXCEPTION; } return outputFuture; } }
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Fri Oct 18 22:10:29 UTC 2024 - 6.2K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/FuturesTransformAsyncTest.java
outputFuture.set(RESULT_DATA); break; case SLOW_OUTPUT_VALID_INPUT_DATA: break; // do nothing to the result case SLOW_FUNC_VALID_INPUT_DATA: funcIsWaitingLatch.countDown(); awaitUninterruptibly(funcCompletionLatch); break; case EXCEPTION_DATA: throw EXCEPTION; } return outputFuture; } }
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Fri Oct 18 22:10:29 UTC 2024 - 6.2K bytes - Viewed (0) -
android/guava-testlib/src/com/google/common/util/concurrent/testing/MockFutureListener.java
this.countDownLatch = new CountDownLatch(1); this.future = future; future.addListener(this, directExecutor()); } @Override public void run() { countDownLatch.countDown(); } /** * Verify that the listener completes in a reasonable amount of time, and Asserts that the future * returns the expected data. *
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Fri May 12 18:12:42 UTC 2023 - 3K bytes - Viewed (0)