- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 87 for Kistner (0.15 sec)
-
okhttp-sse/src/main/kotlin/okhttp3/sse/EventSources.kt
return EventSource.Factory { request, listener -> val actualRequest = if (request.header("Accept") == null) { request.newBuilder().addHeader("Accept", "text/event-stream").build() } else { request } RealEventSource(actualRequest, listener).apply { connect(callFactory) } } } @JvmStatic
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sat Apr 06 04:18:15 GMT 2024 - 1.6K bytes - Viewed (1) -
maven-core/src/test/java/org/apache/maven/lifecycle/DelegatingMojoExecutionListener.java
for (MojoExecutionListener listener : listeners) { listener.afterExecutionFailure(event); } } public void addMojoExecutionListener(MojoExecutionListener listener) { this.listeners.add(listener); } public void removeMojoExecutionListener(MojoExecutionListener listener) { this.listeners.remove(listener); }
Java - Registered: Sun Apr 28 03:35:10 GMT 2024 - Last Modified: Mon Dec 26 15:12:32 GMT 2022 - 2.2K bytes - Viewed (0) -
okhttp-sse/src/test/java/okhttp3/sse/internal/EventSourcesHttpTest.kt
val request = Request.Builder() .url(server.url("/")) .build() val response = client.newCall(request).execute() processResponse(response, listener) listener.assertOpen() listener.assertEvent(null, null, "hey") listener.assertClose() } @Test fun cancelShortCircuits() { server.enqueue( MockResponse.Builder() .body( """ |data: hey
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sun Jan 14 10:20:09 GMT 2024 - 2.6K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/cache/NullCacheTest.java
QueuingRemovalListener<Object, Object> listener; @Override protected void setUp() { listener = queuingRemovalListener(); } public void testGet() { Object computed = new Object(); LoadingCache<Object, Object> cache = CacheBuilder.newBuilder() .maximumSize(0) .removalListener(listener) .build(constantLoader(computed));
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Wed Sep 06 17:04:31 GMT 2023 - 4.4K bytes - Viewed (0) -
maven-compat/src/test/java/org/apache/maven/artifact/resolver/TestFileWagon.java
return super.getIfNewer(resourceName, destination, timestamp); } public void addTransferListener(TransferListener listener) { if (listener instanceof TestTransferListener) { testTransferListener = (TestTransferListener) listener; } super.addTransferListener(listener); }
Java - Registered: Sun May 05 03:35:11 GMT 2024 - Last Modified: Thu Apr 25 05:46:50 GMT 2024 - 2.8K bytes - Viewed (0) -
istioctl/pkg/authz/analyzer.go
if err != nil { return nil, fmt.Errorf("failed to get dynamic listener dump: %s", err) } return &Analyzer{listenerDump: listeners}, nil } // Print print the analysis results. func (a *Analyzer) Print(writer io.Writer) { var listeners []*listener.Listener for _, l := range a.listenerDump.DynamicListeners { listenerTyped := &listener.Listener{} // Support v2 or v3 in config dump. See ads.go:RequestedTypes for more info.
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Wed Jul 13 01:59:17 GMT 2022 - 2.1K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/ListenerCallQueue.java
void call(L listener); } /** * Adds a listener that will be called using the given executor when events are later {@link * #enqueue enqueued} and {@link #dispatch dispatched}. */ public void addListener(L listener, Executor executor) { checkNotNull(listener, "listener"); checkNotNull(executor, "executor"); listeners.add(new PerListenerQueue<>(listener, executor)); } /**
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Wed Dec 13 19:45:20 GMT 2023 - 8.2K bytes - Viewed (0) -
maven-core/src/main/java/org/apache/maven/lifecycle/internal/DefaultExecutionEventCatapult.java
listener.sessionStarted(event); break; case SessionEnded: listener.sessionEnded(event); break; case ProjectSkipped: listener.projectSkipped(event); break; case ProjectStarted: listener.projectStarted(event); break;
Java - Registered: Sun May 05 03:35:11 GMT 2024 - Last Modified: Wed Jan 10 12:55:54 GMT 2024 - 4.1K bytes - Viewed (0) -
guava-tests/test/com/google/common/cache/NullCacheTest.java
QueuingRemovalListener<Object, Object> listener; @Override protected void setUp() { listener = queuingRemovalListener(); } public void testGet() { Object computed = new Object(); LoadingCache<Object, Object> cache = CacheBuilder.newBuilder() .maximumSize(0) .removalListener(listener) .build(constantLoader(computed));
Java - Registered: Fri Apr 19 12:43:09 GMT 2024 - Last Modified: Wed Sep 06 17:04:31 GMT 2023 - 4.4K bytes - Viewed (0) -
okhttp-sse/src/test/java/okhttp3/sse/internal/EventSourceHttpTest.kt
).setHeader("content-type", "text/event-stream") .build(), ) val source = newEventSource() assertThat(source.request().url.encodedPath).isEqualTo("/") listener.assertOpen() listener.assertEvent(null, null, "hey") listener.assertClose() } @RetryingTest(5) fun cancelInEventShortCircuits() { server.enqueue( MockResponse.Builder() .body( """
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sun Jan 14 10:20:09 GMT 2024 - 6.6K bytes - Viewed (0)