- Sort Score
- Result 10 results
- Languages All
Results 41 - 50 of 72 for AddListener (0.25 sec)
-
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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)