- Sort Score
- Result 10 results
- Languages All
Results 41 - 50 of 87 for Listener (0.8 sec)
-
android/guava/src/com/google/common/util/concurrent/ExecutionSequencer.java
} }; // Adding the listener to both futures guarantees that newFuture will always be set. Adding to // taskFuture guarantees completion if the callable is invoked, and adding to outputFuture // propagates cancellation if the callable has not yet been invoked. outputFuture.addListener(listener, directExecutor()); taskFuture.addListener(listener, directExecutor()); return outputFuture; }
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Thu Feb 01 21:46:34 GMT 2024 - 22.1K bytes - Viewed (0) -
maven-core/src/main/java/org/apache/maven/plugin/version/internal/DefaultPluginVersionResolver.java
org.eclipse.aether.metadata.Metadata metadata, ArtifactRepository repository, Exception exception) { RepositoryListener listener = session.getRepositoryListener(); if (listener != null) { RepositoryEvent.Builder event = new RepositoryEvent.Builder(session, EventType.METADATA_INVALID); event.setTrace(trace); event.setMetadata(metadata);
Java - Registered: Sun May 05 03:35:11 GMT 2024 - Last Modified: Fri Sep 22 09:07:17 GMT 2023 - 15.7K bytes - Viewed (0) -
maven-core/src/main/java/org/apache/maven/DefaultMaven.java
void run(AbstractMavenLifecycleParticipant listener, MavenSession session) throws MavenExecutionException; } private void callListeners(MavenSession session, ListenerMethod method) throws MavenExecutionException { ClassLoader originalClassLoader = Thread.currentThread().getContextClassLoader(); try { for (AbstractMavenLifecycleParticipant listener :
Java - Registered: Sun May 05 03:35:11 GMT 2024 - Last Modified: Fri Apr 12 10:50:18 GMT 2024 - 27.5K bytes - Viewed (0) -
android/guava/src/com/google/common/cache/CacheBuilder.java
return ticker; } return recordsTime ? Ticker.systemTicker() : NULL_TICKER; } /** * Specifies a listener instance that caches should notify each time an entry is removed for any * {@linkplain RemovalCause reason}. Each cache created by this builder will invoke this listener * as part of the routine maintenance described in the class documentation above. *
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Thu Feb 15 16:12:13 GMT 2024 - 44.8K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/MoreExecutorsTest.java
} finally { joinPool(e); } } private static void assertListenerRunImmediately(ListenableFuture<?> future) { CountingRunnable listener = new CountingRunnable(); future.addListener(listener, directExecutor()); assertEquals(1, listener.count); } private static final class CountingRunnable implements Runnable { int count; @Override public void run() {
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Wed Sep 06 17:04:31 GMT 2023 - 28.2K bytes - Viewed (0) -
okhttp-testing-support/src/main/kotlin/okhttp3/OkHttpClientTestRule.kt
/** * Returns an OkHttpClient for tests to use as a starting point. * * The returned client installs a default event listener that gathers debug information. This will * be logged if the test fails. * * This client is also configured to be slightly more deterministic, returning a single IP
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 10.5K bytes - Viewed (0) -
mockwebserver/src/main/kotlin/mockwebserver3/MockResponse.kt
* This will overwrite any previously set status, body, or streamHandler. */ fun webSocketUpgrade(listener: WebSocketListener) = apply { status = "HTTP/1.1 101 Switching Protocols" setHeader("Connection", "Upgrade") setHeader("Upgrade", "websocket") webSocketListener = listener } /**
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Tue Jan 23 14:31:42 GMT 2024 - 13.3K bytes - Viewed (1) -
android/guava-tests/test/com/google/common/util/concurrent/AbstractFutureBenchmarks.java
*/ @Override public void addListener(Runnable listener, Executor exec) { executionList.add(listener, exec); } /** * Subclasses should invoke this method to set the result of the computation to {@code value}. * This will set the state of the future to {@link OldAbstractFuture.Sync#COMPLETED} and invoke * the listeners if the state was successfully changed. *
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Thu Apr 06 12:56:11 GMT 2023 - 13.6K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/MoreExecutorsTest.java
} finally { joinPool(e); } } private static void assertListenerRunImmediately(ListenableFuture<?> future) { CountingRunnable listener = new CountingRunnable(); future.addListener(listener, directExecutor()); assertEquals(1, listener.count); } private static final class CountingRunnable implements Runnable { int count; @Override public void run() {
Java - Registered: Fri Apr 12 12:43:09 GMT 2024 - Last Modified: Wed Sep 06 17:04:31 GMT 2023 - 28.2K bytes - Viewed (3) -
okhttp/src/test/java/okhttp3/RouteFailureTest.kt
val platform = PlatformRule() @RegisterExtension val clientTestRule = OkHttpClientTestRule() private lateinit var server1: MockWebServer private lateinit var server2: MockWebServer private var listener = RecordingEventListener() private val handshakeCertificates = platform.localhostHandshakeCertificates() val dns = FakeDns() val ipv4 = InetAddress.getByName("203.0.113.1")
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sat Jan 20 10:30:28 GMT 2024 - 11.9K bytes - Viewed (0)