- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 147 for listeners (0.18 sec)
-
maven-core/src/main/java/org/apache/maven/plugin/CompoundMojoExecutionListener.java
private final Collection<MojoExecutionListener> listeners; CompoundMojoExecutionListener(Collection<MojoExecutionListener> listeners) { this.listeners = listeners; // NB this is live injected collection } public void beforeMojoExecution(MojoExecutionEvent event) throws MojoExecutionException { for (MojoExecutionListener listener : listeners) { listener.beforeMojoExecution(event); } }
Java - Registered: Sun May 05 03:35:11 GMT 2024 - Last Modified: Mon Dec 26 15:12:32 GMT 2022 - 1.9K bytes - Viewed (0) -
maven-core/src/test/java/org/apache/maven/lifecycle/DelegatingMojoExecutionListener.java
for (MojoExecutionListener listener : listeners) { listener.afterMojoExecutionSuccess(event); } } public void afterExecutionFailure(MojoExecutionEvent event) { for (MojoExecutionListener listener : listeners) { listener.afterExecutionFailure(event); } } public void addMojoExecutionListener(MojoExecutionListener listener) { this.listeners.add(listener);
Java - Registered: Sun Apr 28 03:35:10 GMT 2024 - Last Modified: Mon Dec 26 15:12:32 GMT 2022 - 2.2K bytes - Viewed (0) -
maven-compat/src/main/java/org/apache/maven/repository/legacy/resolver/DefaultLegacyArtifactCollector.java
return updateScope; } private void fireEvent(int event, List<ResolutionListener> listeners, ResolutionNode node) { fireEvent(event, listeners, node, null); } private void fireEvent(int event, List<ResolutionListener> listeners, ResolutionNode node, Artifact replacement) { fireEvent(event, listeners, node, replacement, null); } private void fireEvent( int event,
Java - Registered: Sun May 05 03:35:11 GMT 2024 - Last Modified: Wed Sep 06 11:28:54 GMT 2023 - 36.7K bytes - Viewed (0) -
guava-gwt/src-super/com/google/common/util/concurrent/super/com/google/common/util/concurrent/AbstractFuture.java
checkNotNull(unit); return get(); } @Override public void addListener(Runnable runnable, Executor executor) { Listener listener = new Listener(runnable, executor); if (isDone()) { listener.execute(); } else { listeners.add(listener); } } @CanIgnoreReturnValue protected boolean setException(Throwable throwable) { checkNotNull(throwable);
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Mon Jan 22 19:37:41 GMT 2024 - 12.3K 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) -
android/guava/src/com/google/common/util/concurrent/AbstractService.java
} /** @since 13.0 */ @Override public final void addListener(Listener listener, Executor executor) { listeners.addListener(listener, executor); } @Override public String toString() { return getClass().getSimpleName() + " [" + state() + "]"; } /** * Attempts to execute all the listeners in {@link #listeners} while not holding the {@link * #monitor}. */
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Fri May 12 18:32:03 GMT 2023 - 20.4K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/ServiceManagerTest.java
RecordingListener listener = new RecordingListener(); manager.addListener(listener, directExecutor()); manager.startAsync().awaitHealthy(); assertTrue(manager.isHealthy()); assertTrue(listener.healthyCalled); assertFalse(listener.stoppedCalled); assertTrue(listener.failedServices.isEmpty()); manager.stopAsync().awaitStopped();
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Mon Oct 02 17:20:27 GMT 2023 - 23.2K bytes - Viewed (0) -
android/guava-testlib/src/com/google/common/util/concurrent/testing/AbstractListenableFutureTest.java
exec.shutdown(); exec.awaitTermination(100, MILLISECONDS); } /** * Tests that all listeners complete, even if they were added before or after the future was * finishing. Also acts as a concurrency test to make sure the locking is done correctly when a * future is finishing so that no listeners can be lost. */ public void testAllListenersCompleteSuccessfully()
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Wed Sep 06 18:30:30 GMT 2023 - 6K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/AbstractFuture.java
if (!isDone()) { Listener oldHead = listeners; if (oldHead != Listener.TOMBSTONE) { Listener newNode = new Listener(listener, executor); do { newNode.next = oldHead; if (ATOMIC_HELPER.casListeners(this, oldHead, newNode)) { return; } oldHead = listeners; // re-read } while (oldHead != Listener.TOMBSTONE);
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Mon Apr 22 21:17:24 GMT 2024 - 63K bytes - Viewed (0) -
maven-core/src/test/java/org/apache/maven/lifecycle/DelegatingProjectExecutionListener.java
for (ProjectExecutionListener listener : listeners) { listener.afterProjectExecutionFailure(event); } } public void addProjectExecutionListener(ProjectExecutionListener listener) { this.listeners.add(listener); } public void removeProjectExecutionListener(ProjectExecutionListener listener) { this.listeners.remove(listener); }
Java - Registered: Sun Apr 28 03:35:10 GMT 2024 - Last Modified: Mon Dec 26 15:12:32 GMT 2022 - 2.4K bytes - Viewed (0)