Search Options

Results per page
Sort
Preferred Languages
Advance

Results 41 - 50 of 203 for AddListener (0.14 sec)

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

        }
    
        @Override
        public final boolean isCancelled() {
          return super.isCancelled();
        }
    
        @Override
        public final void addListener(Runnable listener, Executor executor) {
          super.addListener(listener, executor);
        }
    
        @CanIgnoreReturnValue
        @Override
        public final boolean cancel(boolean mayInterruptIfRunning) {
    Registered: Wed Jun 12 16:38:11 UTC 2024
    - Last Modified: Tue Apr 11 19:08:44 UTC 2023
    - 19.6K bytes
    - Viewed (0)
  2. platforms/core-configuration/configuration-cache/src/main/kotlin/org/gradle/internal/cc/impl/fingerprint/ConfigurationCacheFingerprintController.kt

                    writingState.append(fingerprint)
                }
            }
    
        private
        fun addListener(listener: ConfigurationCacheFingerprintWriter) {
            listenerManager.addListener(listener)
            workInputListeners.addListener(listener)
            scriptFileResolverListeners.addListener(listener)
        }
    
        private
        fun removeListener(listener: ConfigurationCacheFingerprintWriter) {
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Tue Jun 11 09:51:15 UTC 2024
    - 18.3K bytes
    - Viewed (0)
  3. 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: Wed Jun 12 16:38:11 UTC 2024
    - Last Modified: Thu Feb 01 21:46:34 UTC 2024
    - 7.7K bytes
    - Viewed (0)
  4. platforms/core-runtime/build-state/src/test/java/org/gradle/internal/session/BuildSessionStateTest.groovy

        }
    
        def "does nothing when function does nothing"() {
            def listener = Mock(BuildSessionLifecycleListener)
            def action = Mock(Function)
    
            given:
            listenerManager.addListener(listener)
    
            when:
            state.run(action)
    
            then:
            1 * action.apply(_)
            0 * actionExecutor._
            0 * listener._
        }
    
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Mon May 13 21:54:27 UTC 2024
    - 3.6K bytes
    - Viewed (0)
  5. guava/src/com/google/common/util/concurrent/ListenableFutureTask.java

     * FutureTask}, {@code ListenableFutureTask} does not provide an overrideable {@link
     * FutureTask#done() done()} method. For similar functionality, call {@link #addListener}.
     *
     * <p>Few users should use this class. It is intended primarily for those who are implementing an
     * {@code ExecutorService}. Most users should call {@link ListeningExecutorService#submit(Callable)
    Registered: Wed Jun 12 16:38:11 UTC 2024
    - Last Modified: Tue Apr 04 09:45:04 UTC 2023
    - 4.3K bytes
    - Viewed (0)
  6. guava-tests/test/com/google/common/util/concurrent/AbstractFutureTest.java

          // For each listener we add a task that submits it to the executor directly for the blocking
          // get use case and another task that adds it as a listener to the future to exercise both
          // racing addListener calls and addListener calls completing after the future completes.
          final Runnable listener =
              k % 2 == 0 ? collectResultsRunnable : collectResultsTimedGetRunnable;
          allTasks.add(Executors.callable(listener));
    Registered: Wed Jun 12 16:38:11 UTC 2024
    - Last Modified: Tue Jun 11 16:13:05 UTC 2024
    - 46.7K bytes
    - Viewed (0)
  7. android/guava/src/com/google/common/util/concurrent/FluentFuture.java

        }
    
        @Override
        public final boolean isCancelled() {
          return super.isCancelled();
        }
    
        @Override
        public final void addListener(Runnable listener, Executor executor) {
          super.addListener(listener, executor);
        }
    
        @CanIgnoreReturnValue
        @Override
        public final boolean cancel(boolean mayInterruptIfRunning) {
    Registered: Wed Jun 12 16:38:11 UTC 2024
    - Last Modified: Tue Apr 11 19:08:44 UTC 2023
    - 18.7K bytes
    - Viewed (0)
  8. platforms/core-runtime/launcher/src/main/java/org/gradle/launcher/daemon/server/scaninfo/DefaultDaemonScanInfo.java

                            }
                        }
                    }
                }
            };
            daemonExpirationListenerReference.set(daemonExpirationListener);
            listenerManager.addListener(daemonExpirationListener);
    
            final BuildAdapter buildListener = new InternalBuildAdapter() {
                @Override
                public void buildFinished(BuildResult result) {
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Fri Sep 22 09:29:13 UTC 2023
    - 4.9K bytes
    - Viewed (0)
  9. subprojects/core/src/main/java/org/gradle/internal/scripts/ScriptFileResolverListeners.java

    import org.gradle.internal.service.scopes.Scope;
    import org.gradle.internal.service.scopes.ServiceScope;
    
    @ServiceScope(Scope.Global.class)
    public interface ScriptFileResolverListeners {
    
        void addListener(ScriptFileResolvedListener scriptFileResolvedListener);
    
        void removeListener(ScriptFileResolvedListener scriptFileResolvedListener);
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Tue Mar 12 02:21:10 UTC 2024
    - 1003 bytes
    - Viewed (0)
  10. android/guava/src/com/google/common/util/concurrent/AbstractIdleService.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: Wed Jun 12 16:38:11 UTC 2024
    - Last Modified: Mon Apr 17 13:59:28 UTC 2023
    - 5.3K bytes
    - Viewed (0)
Back to top