Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 65 for listeners (0.04 sec)

  1. guava-gwt/src-super/com/google/common/util/concurrent/super/com/google/common/util/concurrent/AbstractFutureState.java

      final @Nullable Listener listeners() {
        return listeners;
      }
    
      final void releaseWaiters() {}
    
      AbstractFutureState() {}
    
      static final Object NULL = new Object();
    
      static final LazyLogger log = new LazyLogger(AbstractFuture.class);
    
      static final boolean GENERATE_CANCELLATION_CAUSES = false;
    
      private volatile @Nullable Object value;
    
      private volatile @Nullable Listener listeners;
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Fri Feb 21 02:38:37 UTC 2025
    - 1.9K bytes
    - Viewed (0)
  2. 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)
  3. guava/src/com/google/common/util/concurrent/ExecutionList.java

     * instance contains a list of listeners, each with an associated {@code Executor}, and guarantees
     * that every {@code Runnable} that is {@linkplain #add added} will be executed after {@link
     * #execute()} is called. Any {@code Runnable} added after the call to {@code execute} is still
     * guaranteed to execute. There is no guarantee, however, that listeners will be executed in the
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Sun Dec 22 03:38:46 UTC 2024
    - 6.9K 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 Sep 05 12:43:10 UTC 2025
    - Last Modified: Mon Mar 17 20:26:29 UTC 2025
    - 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 Sep 05 12:43:10 UTC 2025
    - Last Modified: Mon Mar 17 20:26:29 UTC 2025
    - 8K bytes
    - Viewed (0)
  6. android/guava/src/com/google/common/util/concurrent/ExecutionList.java

     * instance contains a list of listeners, each with an associated {@code Executor}, and guarantees
     * that every {@code Runnable} that is {@linkplain #add added} will be executed after {@link
     * #execute()} is called. Any {@code Runnable} added after the call to {@code execute} is still
     * guaranteed to execute. There is no guarantee, however, that listeners will be executed in the
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Sun Dec 22 03:38:46 UTC 2024
    - 6.9K bytes
    - Viewed (0)
  7. 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 Sep 05 11:42:10 UTC 2025
    - Last Modified: Thu Aug 12 07:26:27 UTC 2021
    - 3.8K bytes
    - Viewed (0)
  8. guava/src/com/google/common/util/concurrent/ListenableFutureTask.java

        super(callable);
      }
    
      ListenableFutureTask(Runnable runnable, @ParametricNullness V result) {
        super(runnable, result);
      }
    
      @Override
      public void addListener(Runnable listener, Executor exec) {
        executionList.add(listener, exec);
      }
    
      @CanIgnoreReturnValue
      @Override
      @ParametricNullness
      public V get(long timeout, TimeUnit unit)
          throws TimeoutException, InterruptedException, ExecutionException {
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Sun Dec 22 03:38:46 UTC 2024
    - 4.2K bytes
    - Viewed (0)
  9. 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)
  10. android/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 Sep 05 12:43:10 UTC 2025
    - Last Modified: Mon Mar 17 20:26:29 UTC 2025
    - 8K bytes
    - Viewed (0)
Back to top