- Sort Score
- Result 10 results
- Languages All
Results 41 - 50 of 129 for Kistner (0.19 sec)
-
android/guava-tests/test/com/google/common/util/concurrent/ListenerCallQueueTest.java
queue.enqueue(incrementingEvent(counters, listener, 2)); queue.enqueue(incrementingEvent(counters, listener, 3)); queue.enqueue(incrementingEvent(counters, listener, 4)); queue.enqueue(countDownEvent(latch)); assertEquals(0, counters.size()); queue.dispatch(); latch.await(); assertEquals(multiset(listener, 4), counters); } finally {
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Wed Feb 09 22:57:07 GMT 2022 - 8.2K bytes - Viewed (0) -
guava-tests/test/com/google/common/cache/NullCacheTest.java
QueuingRemovalListener<Object, Object> listener; @Override protected void setUp() { listener = queuingRemovalListener(); } public void testGet() { Object computed = new Object(); LoadingCache<Object, Object> cache = CacheBuilder.newBuilder() .maximumSize(0) .removalListener(listener) .build(constantLoader(computed));
Java - Registered: Fri Apr 19 12:43:09 GMT 2024 - Last Modified: Wed Sep 06 17:04:31 GMT 2023 - 4.4K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/AbstractServiceTest.java
throw exception; } } private static class RecordingListener extends Listener { static RecordingListener record(Service service) { RecordingListener listener = new RecordingListener(service); service.addListener(listener, directExecutor()); return listener; } final Service service; RecordingListener(Service service) {
Java - Registered: Fri Apr 12 12:43:09 GMT 2024 - Last Modified: Wed Sep 06 17:04:31 GMT 2023 - 29.3K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/AbstractAbstractFutureTest.java
CountingRunnable listener = new CountingRunnable(); future.addListener(listener, directExecutor()); listener.assertNotRun(); future.set(1); listener.assertRun(); } public void testListenLaterFailed() { CountingRunnable listener = new CountingRunnable(); future.addListener(listener, directExecutor()); listener.assertNotRun();
Java - Registered: Fri Apr 12 12:43:09 GMT 2024 - Last Modified: Tue Feb 13 14:28:25 GMT 2024 - 15.5K bytes - Viewed (0) -
maven-compat/src/main/java/org/apache/maven/repository/legacy/TransferListenerAdapter.java
private final ArtifactTransferListener listener; private final Map<Resource, ArtifactTransferResource> artifacts; private final Map<Resource, Long> transfers; public static TransferListener newAdapter(ArtifactTransferListener listener) { if (listener == null) { return null; } else { return new TransferListenerAdapter(listener); } }
Java - Registered: Sun May 05 03:35:11 GMT 2024 - Last Modified: Wed Sep 06 11:28:54 GMT 2023 - 5K bytes - Viewed (0) -
samples/slack/src/main/java/okhttp3/slack/OAuthSessionFactory.java
Listener listener; synchronized (this) { listener = listeners.get(state); } if (code == null || listener == null) { return new MockResponse() .setResponseCode(404) .setBody("unexpected request"); } try { OAuthSession session = slackApi.exchangeCode(code, redirectUrl()); listener.sessionGranted(session);
Java - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Thu Aug 12 07:26:27 GMT 2021 - 3.8K bytes - Viewed (0) -
build-logic/documentation/src/main/groovy/gradlebuild/docs/dsl/docbook/JavadocLinkConverter.java
/** * Converts a javadoc link into docbook. */ public Node resolve(String link, ClassMetaData classMetaData, GenerationListener listener) { Node node = doResolve(link, classMetaData, listener); if (node != null) { return node; } listener.warning(String.format("Could not convert Javadoc link '%s'", link)); Element element = document.createElement("UNHANDLED-LINK");
Java - Registered: Wed Apr 17 11:36:08 GMT 2024 - Last Modified: Wed Dec 09 08:14:05 GMT 2020 - 7K bytes - Viewed (0) -
build-logic/documentation/src/main/groovy/gradlebuild/docs/dsl/docbook/BlockDetailRenderer.java
public class BlockDetailRenderer { private final GenerationListener listener; private final LinkRenderer linkRenderer; private final ElementWarningsRenderer warningsRenderer = new ElementWarningsRenderer(); public BlockDetailRenderer(LinkRenderer linkRenderer, GenerationListener listener) { this.linkRenderer = linkRenderer; this.listener = listener; } public void renderTo(BlockDoc blockDoc, Element parent) {
Java - Registered: Wed May 01 11:36:15 GMT 2024 - Last Modified: Wed Dec 09 08:14:05 GMT 2020 - 3.7K bytes - Viewed (0) -
android/guava-testlib/src/com/google/common/util/concurrent/testing/MockFutureListener.java
} /** * Verify that the listener completes in a reasonable amount of time, and Asserts that the future * returns the expected data. * * @throws Throwable if the listener isn't called or if it resulted in a throwable or if the * result doesn't match the expected value. */ public void assertSuccess(Object expectedData) throws Throwable { // Verify that the listener executed in a reasonable amount of time.
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Fri May 12 18:12:42 GMT 2023 - 3K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/ImmediateFuture.java
} @Override @SuppressWarnings("CatchingUnchecked") // sneaky checked exception public void addListener(Runnable listener, Executor executor) { checkNotNull(listener, "Runnable was null."); checkNotNull(executor, "Executor was null."); try { executor.execute(listener); } catch (Exception e) { // sneaky checked exception
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Wed Dec 13 19:45:20 GMT 2023 - 3.5K bytes - Viewed (0)