Search Options

Results per page
Sort
Preferred Languages
Advance

Results 41 - 50 of 72 for AddListener (0.25 sec)

  1. 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: Wed Jun 12 16:38:11 UTC 2024
    - Last Modified: Wed Dec 13 19:45:20 UTC 2023
    - 27.5K bytes
    - Viewed (0)
  2. platforms/core-execution/workers/src/main/java/org/gradle/workers/internal/WorkerDaemonClientsManager.java

            this.listenerManager = listenerManager;
            this.loggingManager = loggingManager;
            this.memoryInfo = memoryInfo;
            this.stopSessionScopeWorkers = new StopSessionScopedWorkers();
            listenerManager.addListener(stopSessionScopeWorkers);
            this.logLevelChangeEventListener = new LogLevelChangeEventListener();
            loggingManager.addOutputEventListener(logLevelChangeEventListener);
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Thu May 30 19:54:37 UTC 2024
    - 10K bytes
    - Viewed (0)
  3. android/guava/src/com/google/common/util/concurrent/AbstractService.java

      /** @since 14.0 */
      @Override
      public final Throwable failureCause() {
        return snapshot.failureCause();
      }
    
      /** @since 13.0 */
      @Override
      public final void addListener(Listener listener, Executor executor) {
        listeners.addListener(listener, executor);
      }
    
      @Override
      public String toString() {
        return getClass().getSimpleName() + " [" + state() + "]";
      }
    
      /**
    Registered: Wed Jun 12 16:38:11 UTC 2024
    - Last Modified: Fri May 12 18:32:03 UTC 2023
    - 20.4K bytes
    - Viewed (0)
  4. platforms/software/dependency-management/src/main/java/org/gradle/api/internal/artifacts/DependencyManagementBuildScopeServices.java

            ListenerManager listenerManager
        ) {
            if (cacheDecoratorFactory instanceof CleaningInMemoryCacheDecoratorFactory) {
                listenerManager.addListener(new BuildModelLifecycleListener() {
                    @Override
                    public void beforeModelDiscarded(GradleInternal model, boolean buildFailed) {
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Mon May 27 12:34:44 UTC 2024
    - 28.4K bytes
    - Viewed (0)
  5. guava/src/com/google/common/util/concurrent/AbstractService.java

      /** @since 14.0 */
      @Override
      public final Throwable failureCause() {
        return snapshot.failureCause();
      }
    
      /** @since 13.0 */
      @Override
      public final void addListener(Listener listener, Executor executor) {
        listeners.addListener(listener, executor);
      }
    
      @Override
      public String toString() {
        return getClass().getSimpleName() + " [" + state() + "]";
      }
    
      /**
    Registered: Wed Jun 12 16:38:11 UTC 2024
    - Last Modified: Fri May 12 18:32:03 UTC 2023
    - 20.7K bytes
    - Viewed (0)
  6. platforms/core-execution/worker-main/src/main/java/org/gradle/process/internal/worker/child/SystemApplicationClassLoaderWorker.java

            final WorkerJvmMemoryInfoProtocol workerJvmMemoryInfoProtocol = connection.addOutgoing(WorkerJvmMemoryInfoProtocol.class);
            services.get(MemoryManager.class).addListener(new JvmMemoryStatusListener() {
                @Override
                public void onJvmMemoryStatus(JvmMemoryStatus jvmMemoryStatus) {
                    workerJvmMemoryInfoProtocol.sendJvmMemoryStatus(jvmMemoryStatus);
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Mon May 27 12:34:44 UTC 2024
    - 11.9K bytes
    - Viewed (0)
  7. platforms/core-runtime/messaging/src/test/groovy/org/gradle/internal/event/DefaultListenerManagerInServiceRegistryTest.groovy

        }
    
        def "creates stateful listener registered after another listener added"() {
            def created = Mock(Runnable)
            def listener = Mock(TestListener)
    
            when:
            listenerManager.addListener(Stub(TestListener))
            services.addProvider(new ServiceRegistrationProvider() {
                @Provides
                TestListener createListener() {
                    created.run()
                    return listener
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Mon May 27 12:34:44 UTC 2024
    - 12.1K bytes
    - Viewed (0)
  8. subprojects/core/src/main/java/org/gradle/internal/service/scopes/GradleUserHomeScopeServices.java

            DefaultClassLoaderCache cache = new DefaultClassLoaderCache(classLoaderFactory, classpathHasher);
            listenerManager.addListener(cache);
            return cache;
        }
    
        @Provides
        ClassLoaderScopeRegistryListenerManager createClassLoaderScopeRegistryListenerManager(ListenerManager listenerManager) {
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Mon May 27 12:34:44 UTC 2024
    - 13.8K bytes
    - Viewed (0)
  9. pkg/kubelet/certificate/kubelet.go

    	}
    	m := &kubeletServerCertificateDynamicFileManager{
    		dynamicCertificateContent: c,
    		certFile:                  certFile,
    		keyFile:                   keyFile,
    	}
    	m.Enqueue()
    	c.AddListener(m)
    	return m, nil
    }
    
    // kubeletServerCertificateDynamicFileManager uses a dynamic CertKeyContentProvider based on cert and key files.
    type kubeletServerCertificateDynamicFileManager struct {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Jun 06 03:07:16 UTC 2024
    - 10.3K bytes
    - Viewed (0)
  10. subprojects/core/src/test/groovy/org/gradle/internal/operations/notify/BuildOperationNotificationBridgeTest.groovy

            when:
            def bridge = getOrCreateBridge()
            bridge.valve.start()
    
            then:
            1 * buildOperationListenerManager.addListener(_) >> {
                buildOperationListener = it[0]
            }
    
            when:
            bridge.valve.stop()
    
            then:
            1 * buildOperationListenerManager.removeListener(_) >> {
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Tue Mar 12 02:21:10 UTC 2024
    - 12.3K bytes
    - Viewed (0)
Back to top