- Sort Score
- Result 10 results
- Languages All
Results 61 - 70 of 256 for Kistner (0.18 sec)
-
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 Apr 26 12:43:10 GMT 2024 - Last Modified: Tue Feb 13 14:28:25 GMT 2024 - 15.5K bytes - Viewed (0) -
maven-compat/src/main/java/org/apache/maven/repository/legacy/TransferListenerAdapter.java
private final ArtifactTransferListener listener; private final Map<Resource, ArtifactTransferResource> artifacts; private final Map<Resource, Long> transfers; public static TransferListener newAdapter(ArtifactTransferListener listener) { if (listener == null) { return null; } else { return new TransferListenerAdapter(listener); } }
Java - Registered: Sun Apr 28 03:35:10 GMT 2024 - Last Modified: Wed Sep 06 11:28:54 GMT 2023 - 5K bytes - Viewed (0) -
samples/slack/src/main/java/okhttp3/slack/OAuthSessionFactory.java
Listener listener; synchronized (this) { listener = listeners.get(state); } if (code == null || listener == null) { return new MockResponse() .setResponseCode(404) .setBody("unexpected request"); } try { OAuthSession session = slackApi.exchangeCode(code, redirectUrl()); listener.sessionGranted(session);
Java - Registered: Fri Apr 26 11:42:10 GMT 2024 - Last Modified: Thu Aug 12 07:26:27 GMT 2021 - 3.8K bytes - Viewed (0) -
okhttp-sse/src/main/kotlin/okhttp3/sse/EventSource.kt
* asynchronous process to connect the socket. Once that succeeds or fails, `listener` will be * notified. The caller must cancel the returned event source when it is no longer in use. */ fun newEventSource( request: Request, listener: EventSourceListener, ): EventSource }
Plain Text - Registered: Fri Apr 26 11:42:10 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 1.4K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/cache/CacheBuilderTest.java
CountingRemovalListener<Object, Object> listener = countingRemovalListener(); LoadingCache<Object, Object> nullCache = CacheBuilder.newBuilder().maximumSize(0).removalListener(listener).build(identityLoader()); assertEquals(0, nullCache.size()); Object key = new Object(); assertSame(key, nullCache.getUnchecked(key)); assertEquals(1, listener.getCount()); assertEquals(0, nullCache.size());
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Tue Oct 03 20:10:02 GMT 2023 - 23.2K bytes - Viewed (0) -
docs/features/events.md
![Events Diagram](../assets/images/******@****.***) Here’s a [sample event listener](https://github.com/square/okhttp/blob/master/samples/guide/src/main/java/okhttp3/recipes/PrintEventsNonConcurrent.java) that prints each event with a timestamp. ```java class PrintingEventListener extends EventListener {
Plain Text - Registered: Fri Apr 26 11:42:10 GMT 2024 - Last Modified: Sun Feb 06 02:19:09 GMT 2022 - 7.7K bytes - Viewed (0) -
build-logic/documentation/src/main/groovy/gradlebuild/docs/dsl/docbook/PropertyDetailRenderer.java
public class PropertyDetailRenderer { private final GenerationListener listener; private final LinkRenderer linkRenderer; private final ElementWarningsRenderer warningsRenderer = new ElementWarningsRenderer(); public PropertyDetailRenderer(LinkRenderer linkRenderer, GenerationListener listener) { this.linkRenderer = linkRenderer; this.listener = listener; }
Java - Registered: Wed Apr 17 11:36:08 GMT 2024 - Last Modified: Wed Dec 09 08:14:05 GMT 2020 - 3.5K bytes - Viewed (0) -
guava/src/com/google/common/cache/RemovalListeners.java
* executor}. * * @param listener the backing listener * @param executor the executor with which removal notifications are asynchronously executed */ public static <K, V> RemovalListener<K, V> asynchronous( RemovalListener<K, V> listener, Executor executor) { checkNotNull(listener); checkNotNull(executor); return (RemovalNotification<K, V> notification) ->
Java - Registered: Fri Apr 05 12:43:09 GMT 2024 - Last Modified: Fri Oct 01 16:02:17 GMT 2021 - 1.5K bytes - Viewed (0) -
maven-core/src/main/java/org/apache/maven/configuration/internal/EnhancedComponentConfigurator.java
final ClassRealm realm, final ConfigurationListener listener) throws ComponentConfigurationException { try { ClassRealmConverter.pushContextRealm(realm); this.configureComponent(component, configuration, evaluator, (ClassLoader) realm, listener); } finally { ClassRealmConverter.popContextRealm(); } }
Java - Registered: Sun Apr 28 03:35:10 GMT 2024 - Last Modified: Mon Feb 05 09:45:47 GMT 2024 - 2.9K bytes - Viewed (0) -
cni/pkg/monitoring/monitoring.go
"istio.io/istio/pkg/network" ) func SetupMonitoring(port int, path string, stop <-chan struct{}) { if port <= 0 { return } mux := http.NewServeMux() var listener net.Listener var err error if listener, err = net.Listen("tcp", fmt.Sprintf(":%d", port)); err != nil { log.Errorf("unable to listen on socket: %v", err) return } exporter, err := monitoring.RegisterPrometheusExporter(nil, nil)
Go - Registered: Wed May 01 22:53:12 GMT 2024 - Last Modified: Fri Jun 09 07:54:01 GMT 2023 - 1.5K bytes - Viewed (0)