Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 119 for listeners (0.05 sec)

  1. compat/maven-compat/src/main/java/org/apache/maven/artifact/resolver/ArtifactResolutionRequest.java

        public List<ResolutionListener> getListeners() {
            return listeners;
        }
    
        public ArtifactResolutionRequest setListeners(List<ResolutionListener> listeners) {
            this.listeners = listeners;
    
            return this;
        }
    
        public ArtifactResolutionRequest addListener(ResolutionListener listener) {
            listeners.add(listener);
    
            return this;
        }
    
    Registered: Sun Sep 07 03:35:12 UTC 2025
    - Last Modified: Fri Jun 06 14:28:57 UTC 2025
    - 8.3K bytes
    - Viewed (0)
  2. src/main/java/jcifs/util/SmbCircuitBreaker.java

        }
    
        /**
         * Add a listener for circuit breaker events
         *
         * @param listener the listener to add
         */
        public void addListener(CircuitBreakerListener listener) {
            if (listener != null) {
                listeners.add(listener);
            }
        }
    
        /**
         * Remove a listener
         *
         * @param listener the listener to remove
         */
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Sat Aug 30 05:58:03 UTC 2025
    - 33.4K bytes
    - Viewed (0)
  3. compat/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,
    Registered: Sun Sep 07 03:35:12 UTC 2025
    - Last Modified: Fri Jun 06 14:28:57 UTC 2025
    - 36.5K bytes
    - Viewed (0)
  4. android/guava/src/com/google/common/util/concurrent/ListenerCallQueue.java

       */
      public void addListener(L listener, Executor executor) {
        checkNotNull(listener, "listener");
        checkNotNull(executor, "executor");
        listeners.add(new PerListenerQueue<>(listener, executor));
      }
    
      /**
       * Enqueues an event to be run on currently known listeners.
       *
       * <p>The {@code toString} method of the Event itself will be used to describe the event in the
       * case of an error.
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Tue May 13 17:27:14 UTC 2025
    - 8.1K bytes
    - Viewed (0)
  5. android/guava/src/com/google/common/util/concurrent/ServiceManager.java

        void enqueueStoppedEvent() {
          listeners.enqueue(STOPPED_EVENT);
        }
    
        void enqueueHealthyEvent() {
          listeners.enqueue(HEALTHY_EVENT);
        }
    
        void enqueueFailedEvent(Service service) {
          listeners.enqueue(
              new ListenerCallQueue.Event<Listener>() {
                @Override
                public void call(Listener listener) {
                  listener.failure(service);
                }
    
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Tue May 13 17:27:14 UTC 2025
    - 33.2K bytes
    - Viewed (1)
  6. compat/maven-compat/src/main/java/org/apache/maven/artifact/resolver/DefaultArtifactResolver.java

                    // won't happen
                }
            }
    
            if (listeners == null) {
                listeners = new ArrayList<>();
    
                if (logger.isDebugEnabled()) {
                    listeners.add(new DebugResolutionListener(logger));
                }
    
                listeners.add(new WarningResolutionListener(logger));
            }
    
    Registered: Sun Sep 07 03:35:12 UTC 2025
    - Last Modified: Fri Jun 06 14:28:57 UTC 2025
    - 25K bytes
    - Viewed (0)
  7. android/guava/src/com/google/common/util/concurrent/JdkFutureAdapters.java

          return delegate;
        }
    
        @Override
        public void addListener(Runnable listener, Executor exec) {
          executionList.add(listener, exec);
    
          // When a listener is first added, we run a task that will wait for the delegate to finish,
          // and when it is done will run the listeners.
          if (hasListeners.compareAndSet(false, true)) {
            if (delegate.isDone()) {
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Thu Jul 17 15:26:41 UTC 2025
    - 7.5K bytes
    - Viewed (0)
  8. src/main/java/jcifs/internal/witness/WitnessClient.java

                    WitnessNotificationListener listener = listeners.get(entry.getKey());
                    if (listener != null) {
                        try {
                            listener.onWitnessNotification(notification);
                        } catch (Exception e) {
                            log.error("Error in witness notification listener", e);
                        }
                    }
                }
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Sat Aug 30 05:58:03 UTC 2025
    - 20.8K bytes
    - Viewed (0)
  9. 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()
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Fri Jul 11 18:52:30 UTC 2025
    - 6.1K bytes
    - Viewed (0)
  10. 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();
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Wed Jul 16 20:34:52 UTC 2025
    - 25.5K bytes
    - Viewed (0)
Back to top