- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 249 for Listeners (0.1 sec)
-
internal/http/listener.go
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Tue Jul 23 10:53:03 UTC 2024 - 5.6K bytes - Viewed (0) -
compat/maven-compat/src/main/java/org/apache/maven/repository/legacy/resolver/DefaultLegacyArtifactCollector.java
return updateScope; } private void fireEvent(int event, List<ResolutionListener> listeners, ResolutionNode node) { fireEvent(event, listeners, node, null); } private void fireEvent(int event, List<ResolutionListener> listeners, ResolutionNode node, Artifact replacement) { fireEvent(event, listeners, node, replacement, null); } private void fireEvent( int event,
Registered: Sun Nov 03 03:35:11 UTC 2024 - Last Modified: Fri Oct 25 12:31:46 UTC 2024 - 36.7K bytes - Viewed (0) -
internal/grid/debug.go
} } addr := l.Addr() hosts = append(hosts, "http://"+addr.String()) listeners = append(listeners, l) } return } func startHTTPServer(listener net.Listener, handler http.Handler) (server *httptest.Server) { server = httptest.NewUnstartedServer(handler) server.Config.Addr = listener.Addr().String() server.Listener = listener server.Start() return server }
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Mon Jul 29 18:10:04 UTC 2024 - 4.4K bytes - Viewed (0) -
istioctl/pkg/writer/compare/listener.go
} diff := difflib.UnifiedDiff{ FromFile: "Istiod Listeners", A: difflib.SplitLines(istiodBytes.String()), ToFile: "Envoy Listeners", B: difflib.SplitLines(envoyBytes.String()), Context: c.context, } text, err := difflib.GetUnifiedDiffString(diff) if err != nil { return err } if text != "" { fmt.Fprintln(c.w, "Listeners Don't Match") fmt.Fprintln(c.w, text) } else {
Registered: Wed Nov 06 22:53:10 UTC 2024 - Last Modified: Thu Apr 04 20:29:08 UTC 2024 - 2K bytes - Viewed (0) -
istioctl/pkg/writer/envoy/configdump/listener.go
if l.Listener != nil { listenerTyped := &listener.Listener{} // Support v2 or v3 in config dump. See ads.go:RequestedTypes for more info. l.Listener.TypeUrl = v3.ListenerType err = l.Listener.UnmarshalTo(listenerTyped) if err != nil { return nil, fmt.Errorf("unmarshal listener: %v", err) } listeners = append(listeners, listenerTyped) } } if len(listeners) == 0 {
Registered: Wed Nov 06 22:53:10 UTC 2024 - Last Modified: Wed Nov 29 12:37:14 UTC 2023 - 18.1K bytes - Viewed (0) -
impl/maven-core/src/main/java/org/apache/maven/internal/impl/EventSpyImpl.java
InternalMavenSession.from(ee.getSession().getSession()); Collection<Listener> listeners = session.getListeners(); if (!listeners.isEmpty()) { Event event = new DefaultEvent(session, ee); for (Listener listener : listeners) { listener.onEvent(event); } } } } @Override
Registered: Sun Nov 03 03:35:11 UTC 2024 - Last Modified: Fri Oct 25 12:31:46 UTC 2024 - 2.1K bytes - Viewed (0) -
compat/maven-compat/src/main/java/org/apache/maven/artifact/resolver/ArtifactResolutionRequest.java
public List<ResolutionListener> getListeners() { return listeners; } public ArtifactResolutionRequest setListeners(List<ResolutionListener> listeners) { this.listeners = listeners; return this; } public ArtifactResolutionRequest addListener(ResolutionListener listener) { listeners.add(listener); return this; }
Registered: Sun Nov 03 03:35:11 UTC 2024 - Last Modified: Fri Oct 25 12:31:46 UTC 2024 - 8.2K bytes - Viewed (0) -
istioctl/pkg/authz/analyzer.go
// Support v2 or v3 in config dump. See ads.go:RequestedTypes for more info. l.ActiveState.Listener.TypeUrl = v3.ListenerType err := l.ActiveState.Listener.UnmarshalTo(listenerTyped) if err != nil { return } listeners = append(listeners, listenerTyped) } Print(writer, listeners)
Registered: Wed Nov 06 22:53:10 UTC 2024 - Last Modified: Wed Jul 13 01:59:17 UTC 2022 - 2.1K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/AbstractService.java
} /** @since 13.0 */ @Override public final void addListener(Listener listener, Executor executor) { listeners.addListener(listener, executor); } @Override public String toString() { return getClass().getSimpleName() + " [" + state() + "]"; } /** * Attempts to execute all the listeners in {@link #listeners} while not holding the {@link * #monitor}. */
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Fri May 12 18:32:03 UTC 2023 - 20.4K bytes - Viewed (0) -
guava-gwt/src-super/com/google/common/util/concurrent/super/com/google/common/util/concurrent/AbstractFuture.java
checkNotNull(unit); return get(); } @Override public void addListener(Runnable runnable, Executor executor) { Listener listener = new Listener(runnable, executor); if (isDone()) { listener.execute(); } else { listeners.add(listener); } } @CanIgnoreReturnValue protected boolean setException(Throwable throwable) { checkNotNull(throwable);
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Mon Jan 22 19:37:41 UTC 2024 - 12.3K bytes - Viewed (0)