- Sort Score
- Result 10 results
- Languages All
Results 41 - 50 of 548 for listener2 (0.22 sec)
-
platforms/core-execution/file-watching/src/main/java/org/gradle/internal/watch/vfs/FileChangeListeners.java
/** * Allows the registration of {@link FileChangeListener}s. * * We can't use listener manager directly, since the listeners will be created in * child scopes of the user home scope. */ @ServiceScope(Scope.UserHome.class) public interface FileChangeListeners { /** * Registers the listener with the build, the listener can be unregistered with {@link #removeListener(FileChangeListener)}. */
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Mar 12 02:21:10 UTC 2024 - 1.4K bytes - Viewed (0) -
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: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Mon Apr 22 21:17:24 UTC 2024 - 6.9K bytes - Viewed (0) -
internal/http/server.go
// Create new HTTP listener. var listener *httpListener listener, listenErrs := newHTTPListener( listenCtx, srv.Addrs, srv.TCPOptions, ) var interfaceFound bool for i := range listenErrs { if listenErrs[i] != nil { listenErrCallback(srv.Addrs[i], listenErrs[i]) } else { interfaceFound = true } } if !interfaceFound {
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri Feb 09 21:25:16 UTC 2024 - 7.7K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/server/dynamiccertificates/configmap_cafile_content.go
return c.configmapNamespace + "/" + c.configmapName } // AddListener adds a listener to be notified when the CA content changes. func (c *ConfigMapCAController) AddListener(listener Listener) { c.listeners = append(c.listeners, listener) } // loadCABundle determines the next set of content for the file. func (c *ConfigMapCAController) loadCABundle() error {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 8.9K bytes - Viewed (0) -
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: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Thu Dec 14 20:35:03 UTC 2023 - 7.5K bytes - Viewed (0) -
pkg/envoy/agent.go
continue } // downstream_cx_active is accounted under "http." and "listener." for http listeners. // Only consider listener stats. Listener stats also will have per worker stats, we can // ignore them. if !strings.HasPrefix(parts[0], "listener.") || strings.Contains(parts[0], "worker_") { continue } // If the stat is for a known Istio listener skip it. if a.knownIstioListeners.Contains(parts[0]) { continue }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Apr 24 16:04:22 UTC 2024 - 9K bytes - Viewed (0) -
platforms/ide/tooling-api/src/crossVersionTest/groovy/org/gradle/integtests/tooling/r25/ProgressCrossVersionSpec.groovy
ProjectConnection connection -> connection.model(BuildInvocations).forTasks('assemble').addProgressListener(events).get() } then: "progress events must be forwarded to the attached listeners" events.assertIsABuild() } def "receive progress events when launching a build"() { given: goodCode() when: "launching a build"
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Sep 26 14:49:20 UTC 2023 - 4.3K bytes - Viewed (0) -
internal/grid/connection_test.go
} t.Logf("host %q should connect to %d hosts", hosts[x], should) } } func startServer(t testing.TB, listener net.Listener, handler http.Handler) (server *httptest.Server) { t.Helper() server = httptest.NewUnstartedServer(handler) server.Config.Addr = listener.Addr().String() server.Listener = listener server.Start() // t.Cleanup(server.Close) t.Log("Started server on", server.Config.Addr, "URL:", server.URL)
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Tue Nov 21 01:09:35 UTC 2023 - 6K bytes - Viewed (0) -
platforms/ide/tooling-api/src/test/groovy/org/gradle/tooling/internal/consumer/parameters/BuildProgressListenerAdapterTest.groovy
given: Map<OperationType, List<ProgressListener>> listeners = operationTypes.collectEntries { [(it): [Stub(ProgressListener)]] } when: def adapter = new BuildProgressListenerAdapter(listeners) then: adapter.subscribedOperations as Set == expectedSubscribedOperations where:
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Sep 26 14:49:20 UTC 2023 - 4.7K bytes - Viewed (0) -
subprojects/core/src/main/java/org/gradle/configuration/internal/ListenerBuildOperationDecorator.java
* * @param cls the type of the listener * @param registrationPoint the place that the listener was registered - used in the operation description / details * @param listener the listener */ <T> T decorate(String registrationPoint, Class<T> cls, T listener); /** * Decorates a listener of unknown type. * <p>
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Apr 04 06:02:19 UTC 2024 - 3.5K bytes - Viewed (0)