Search Options

Results per page
Sort
Preferred Languages
Advance

Results 11 - 20 of 187 for Listeners (0.08 sec)

  1. guava/src/com/google/common/util/concurrent/Service.java

       * across calls to multiple listeners. Specifically, a given listener will have its callbacks
       * invoked in the same order as the underlying service enters those states. Additionally, at most
       * one of the listener's callbacks will execute at once. However, multiple listeners' callbacks
       * may execute concurrently, and listeners may execute in an order different from the one in which
       * they were registered.
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Tue Apr 04 09:45:04 UTC 2023
    - 12.1K bytes
    - Viewed (0)
  2. android/guava/src/com/google/common/util/concurrent/ServiceManager.java

        }
    
        void enqueueStoppedEvent() {
          listeners.enqueue(STOPPED_EVENT);
        }
    
        void enqueueHealthyEvent() {
          listeners.enqueue(HEALTHY_EVENT);
        }
    
        void enqueueFailedEvent(final Service service) {
          listeners.enqueue(
              new ListenerCallQueue.Event<Listener>() {
                @Override
                public void call(Listener listener) {
                  listener.failure(service);
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Sat Oct 19 00:51:36 UTC 2024
    - 33.5K bytes
    - Viewed (0)
  3. guava/src/com/google/common/util/concurrent/ServiceManager.java

        }
    
        void enqueueStoppedEvent() {
          listeners.enqueue(STOPPED_EVENT);
        }
    
        void enqueueHealthyEvent() {
          listeners.enqueue(HEALTHY_EVENT);
        }
    
        void enqueueFailedEvent(final Service service) {
          listeners.enqueue(
              new ListenerCallQueue.Event<Listener>() {
                @Override
                public void call(Listener listener) {
                  listener.failure(service);
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Sat Oct 19 00:51:36 UTC 2024
    - 33.2K bytes
    - Viewed (0)
  4. futures/listenablefuture1/src/com/google/common/util/concurrent/ListenableFuture.java

       * MoreExecutors#directExecutor}. Otherwise, avoid it: See the warnings on the docs for {@code
       * directExecutor}.
       *
       * <p>This is the most general listener interface. For common operations performed using
       * listeners, see {@link Futures}. For a simplified but general listener interface, see {@link
       * Futures#addCallback addCallback()}.
       *
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Mon Jun 26 21:13:41 UTC 2023
    - 8K bytes
    - Viewed (0)
  5. guava/src/com/google/common/util/concurrent/ListenableFuture.java

       * MoreExecutors#directExecutor}. Otherwise, avoid it: See the warnings on the docs for {@code
       * directExecutor}.
       *
       * <p>This is the most general listener interface. For common operations performed using
       * listeners, see {@link Futures}. For a simplified but general listener interface, see {@link
       * Futures#addCallback addCallback()}.
       *
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Mon Jun 26 21:13:41 UTC 2023
    - 8K bytes
    - Viewed (0)
  6. 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}.
       */
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri May 12 18:32:03 UTC 2023
    - 20.7K bytes
    - Viewed (0)
  7. 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 Nov 01 12:43:10 UTC 2024
    - Last Modified: Thu Dec 14 20:35:03 UTC 2023
    - 7.5K bytes
    - Viewed (0)
  8. 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 Nov 03 03:35:11 UTC 2024
    - Last Modified: Fri Oct 25 12:31:46 UTC 2024
    - 24.8K bytes
    - Viewed (0)
  9. 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);
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Thu Aug 12 07:26:27 UTC 2021
    - 3.8K bytes
    - Viewed (0)
  10. android/guava/src/com/google/common/util/concurrent/Service.java

       * across calls to multiple listeners. Specifically, a given listener will have its callbacks
       * invoked in the same order as the underlying service enters those states. Additionally, at most
       * one of the listener's callbacks will execute at once. However, multiple listeners' callbacks
       * may execute concurrently, and listeners may execute in an order different from the one in which
       * they were registered.
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Tue Apr 04 09:45:04 UTC 2023
    - 10.7K bytes
    - Viewed (0)
Back to top