Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 8 of 8 for addListener (0.1 sec)

  1. android/guava/src/com/google/common/util/concurrent/TimeoutFuture.java

        delegate.addListener(fire, directExecutor());
        return result;
      }
    
      /*
       * Memory visibility of these fields. There are two cases to consider.
       *
       * 1. visibility of the writes to these fields to Fire.run:
       *
       * The initial write to delegateRef is made definitely visible via the semantics of
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 25 13:13:32 UTC 2024
    - 8.1K bytes
    - Viewed (0)
  2. compat/maven-compat/src/main/java/org/apache/maven/artifact/resolver/ArtifactResolutionRequest.java

        }
    
        public ArtifactResolutionRequest setListeners(List<ResolutionListener> listeners) {
            this.listeners = listeners;
    
            return this;
        }
    
        public ArtifactResolutionRequest addListener(ResolutionListener listener) {
            listeners.add(listener);
    
            return this;
        }
    
        public Map<String, Artifact> getManagedVersionMap() {
            return managedVersionMap;
        }
    
    Registered: Sun Nov 03 03:35:11 UTC 2024
    - Last Modified: Fri Oct 25 12:31:46 UTC 2024
    - 8.2K bytes
    - Viewed (0)
  3. android/guava/src/com/google/common/util/concurrent/AbstractCatchingFuture.java

          Class<X> exceptionType,
          Function<? super X, ? extends V> fallback,
          Executor executor) {
        CatchingFuture<V, X> future = new CatchingFuture<>(input, exceptionType, fallback);
        input.addListener(future, rejectionPropagatingExecutor(executor, future));
        return future;
      }
    
      static <X extends Throwable, V extends @Nullable Object> ListenableFuture<V> createAsync(
          ListenableFuture<? extends V> input,
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 25 13:13:32 UTC 2024
    - 9.1K bytes
    - Viewed (0)
  4. guava/src/com/google/common/util/concurrent/AbstractTransformFuture.java

          AsyncFunction<? super I, ? extends O> function,
          Executor executor) {
        checkNotNull(executor);
        AsyncTransformFuture<I, O> output = new AsyncTransformFuture<>(input, function);
        input.addListener(output, rejectionPropagatingExecutor(executor, output));
        return output;
      }
    
      static <I extends @Nullable Object, O extends @Nullable Object> ListenableFuture<O> create(
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 25 13:13:32 UTC 2024
    - 11K bytes
    - Viewed (0)
  5. android/guava/src/com/google/common/util/concurrent/AggregateFuture.java

          // Register a listener on each Future in the list to update the state of this future.
          // Note that if all the futures on the list are done prior to completing this loop, the last
          // call to addListener() will callback to setOneValue(), transitively call our cleanup
          // listener, and set this.futures to null.
          // This is not actually a problem, since the foreach only needs this.futures to be non-null
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 25 13:13:32 UTC 2024
    - 16.2K bytes
    - Viewed (0)
  6. android/guava/src/com/google/common/util/concurrent/Futures.java

      // operation in the constructor.
      //
      // 1. In the listener that performs the callback. In this case it is fine since inputFuture is
      //    assigned prior to calling addListener, and addListener happens-before any invocation of the
      //    listener. Notably, this means that 'volatile' is unnecessary to make 'inputFuture' visible
      //    to the listener.
      //
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 25 13:13:32 UTC 2024
    - 64.7K bytes
    - Viewed (0)
  7. guava/src/com/google/common/util/concurrent/Futures.java

      // operation in the constructor.
      //
      // 1. In the listener that performs the callback. In this case it is fine since inputFuture is
      //    assigned prior to calling addListener, and addListener happens-before any invocation of the
      //    listener. Notably, this means that 'volatile' is unnecessary to make 'inputFuture' visible
      //    to the listener.
      //
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 25 13:13:32 UTC 2024
    - 64.4K bytes
    - Viewed (0)
  8. guava/src/com/google/common/util/concurrent/AbstractScheduledService.java

      }
    
      @Override
      public final State state() {
        return delegate.state();
      }
    
      /** @since 13.0 */
      @Override
      public final void addListener(Listener listener, Executor executor) {
        delegate.addListener(listener, executor);
      }
    
      /** @since 14.0 */
      @Override
      public final Throwable failureCause() {
        return delegate.failureCause();
      }
    
      /** @since 15.0 */
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 25 16:22:21 UTC 2024
    - 27.8K bytes
    - Viewed (0)
Back to top