- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 32 for Kistner (0.23 sec)
-
okhttp/src/test/java/okhttp3/internal/ws/RealWebSocketTest.kt
server.processNextFrame() client.listener.assertClosing(1000, "Hello!") server.listener.assertClosing(1000, "Hi!") client.webSocket!!.finishReader() server.webSocket!!.finishReader() client.listener.assertClosed(1000, "Hello!") server.listener.assertClosed(1000, "Hi!") taskFaker.runTasks() assertThat(client.closed).isTrue()
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Thu Apr 11 01:59:58 GMT 2024 - 18.5K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/AbstractAbstractFutureTest.java
CountingRunnable listener = new CountingRunnable(); future.addListener(listener, directExecutor()); listener.assertNotRun(); future.set(1); listener.assertRun(); } public void testListenLaterFailed() { CountingRunnable listener = new CountingRunnable(); future.addListener(listener, directExecutor()); listener.assertNotRun();
Java - Registered: Fri Apr 12 12:43:09 GMT 2024 - Last Modified: Tue Feb 13 14:28:25 GMT 2024 - 15.5K bytes - Viewed (0) -
maven-api-impl/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 Apr 28 03:35:10 GMT 2024 - Last Modified: Tue Apr 23 12:55:57 GMT 2024 - 27.3K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/AbstractAbstractFutureTest.java
CountingRunnable listener = new CountingRunnable(); future.addListener(listener, directExecutor()); listener.assertNotRun(); future.set(1); listener.assertRun(); } public void testListenLaterFailed() { CountingRunnable listener = new CountingRunnable(); future.addListener(listener, directExecutor()); listener.assertNotRun();
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Tue Feb 13 14:28:25 GMT 2024 - 15.5K bytes - Viewed (0) -
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) -
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) -
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) -
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) -
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)