- Sort Score
- Result 10 results
- Languages All
Results 21 - 30 of 83 for Kistner (0.2 sec)
-
maven-compat/src/test/java/org/apache/maven/repository/legacy/DefaultWagonManagerTest.java
events.add(transferEvent); } } TransferListener listener = new TransferListener(); wagonManager.getArtifact(artifact, repos, listener, false); assertEquals(1, listener.events.size()); } @Test void testGetMissingJar() throws TransferFailedException, UnsupportedProtocolException, IOException {
Java - Registered: Sun Apr 28 03:35:10 GMT 2024 - Last Modified: Thu Apr 25 05:46:50 GMT 2024 - 13.4K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/http/CancelTest.kt
} responseBody.close() assertEquals(if (connectionType == H2) 1 else 0, client.connectionPool.connectionCount()) cancelLatch.await() val events = listener.eventSequence.filter { isConnectionEvent(it) }.map { it.name } listener.clearAllEvents() assertThat(events).startsWith("CallStart", "ConnectStart", "ConnectEnd", "ConnectionAcquired") if (cancelMode == CANCEL) {
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sat Jan 20 10:30:28 GMT 2024 - 9.9K bytes - Viewed (0) -
api/maven-api-core/src/main/java/org/apache/maven/api/Session.java
/** * Register the given listener which will receive all events. * * @param listener the listener to register * @throws NullPointerException if {@code listener} is null */ void registerListener(@Nonnull Listener listener); /** * Unregisters a previously registered listener. * * @param listener the listener to unregister
Java - Registered: Sun Apr 28 03:35:10 GMT 2024 - Last Modified: Fri Mar 01 17:18:13 GMT 2024 - 30K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/Service.java
* @since 14.0 */ Throwable failureCause(); /** * Registers a {@link Listener} to be {@linkplain Executor#execute executed} on the given * executor. The listener will have the corresponding transition method called whenever the * service changes state. The listener will not have previous state changes replayed, so it is * suggested that listeners are added before the service starts. *
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Tue Apr 04 09:45:04 GMT 2023 - 10.7K bytes - Viewed (0) -
maven-core/src/main/java/org/apache/maven/internal/impl/AbstractSession.java
} @Override public void registerListener(@Nonnull Listener listener) { listeners.add(nonNull(listener)); } @Override public void unregisterListener(@Nonnull Listener listener) { listeners.remove(nonNull(listener)); } @Nonnull @Override public Collection<Listener> getListeners() { return Collections.unmodifiableCollection(listeners);
Java - Registered: Sun Mar 24 03:35:10 GMT 2024 - Last Modified: Fri Mar 01 17:18:13 GMT 2024 - 21.7K bytes - Viewed (0) -
guava-tests/benchmark/com/google/common/util/concurrent/ExecutionListBenchmark.java
Java - Registered: Fri Apr 19 12:43:09 GMT 2024 - Last Modified: Mon Apr 17 15:19:38 GMT 2023 - 20.4K bytes - Viewed (0) -
api/maven-api-core/src/main/java/org/apache/maven/api/services/ModelBuilderRequest.java
this.modelResolver = modelResolver; return this; } public ModelBuilderRequestBuilder listener(Object listener) { this.listener = listener; return this; } public ModelBuilderRequestBuilder interimResult(ModelBuilderResult interimResult) { this.interimResult = interimResult;
Java - Registered: Sun Apr 28 03:35:10 GMT 2024 - Last Modified: Fri Apr 12 10:50:18 GMT 2024 - 15.7K bytes - Viewed (0) -
cni/pkg/nodeagent/ztunnelserver.go
if err != nil { return nil, fmt.Errorf("failed to listen unix: %w", err) } return &ztunnelServer{ listener: l, conns: &connMgr{ connectionSet: map[*ZtunnelConnection]struct{}{}, }, pods: pods, }, nil } func (z *ztunnelServer) Close() error { return z.listener.Close() } func (z *ztunnelServer) Run(ctx context.Context) { context.AfterFunc(ctx, func() { _ = z.Close() })
Go - Registered: Wed May 01 22:53:12 GMT 2024 - Last Modified: Fri Apr 12 21:47:31 GMT 2024 - 12.4K bytes - Viewed (0) -
maven-compat/src/main/java/org/apache/maven/repository/legacy/resolver/DefaultLegacyArtifactCollector.java
VersionRange newRange) { for (ResolutionListener listener : listeners) { switch (event) { case ResolutionListener.TEST_ARTIFACT: listener.testArtifact(node.getArtifact()); break; case ResolutionListener.PROCESS_CHILDREN: listener.startProcessChildren(node.getArtifact()); break;
Java - Registered: Sun Apr 28 03:35:10 GMT 2024 - Last Modified: Wed Sep 06 11:28:54 GMT 2023 - 36.7K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/http2/Http2Connection.kt
client -> "$okHttpName $peerName" else -> "MockWebServer $peerName" } this.source = source this.sink = sink } fun listener(listener: Listener) = apply { this.listener = listener } fun pushObserver(pushObserver: PushObserver) = apply { this.pushObserver = pushObserver }
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sat Apr 20 17:03:43 GMT 2024 - 32.6K bytes - Viewed (0)