- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 29 for Callbacks (0.35 sec)
-
android/guava/src/com/google/common/util/concurrent/FluentFuture.java
* java.util.concurrent.CompletableFuture#thenAcceptAsync}. * * @param callback The callback to invoke when this {@code Future} is completed. * @param executor The executor to run {@code callback} when the future completes. */ public final void addCallback(FutureCallback<? super V> callback, Executor executor) { Futures.addCallback(this, callback, executor); }
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Tue Apr 11 19:08:44 GMT 2023 - 18.7K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/Service.java
* across calls to multiple listeners. Specifically, a given listener will have its callbacks * invoked in the same order as the underlying service enters those states. Additionally, at most * one of the listener's callbacks will execute at once. However, multiple listeners' callbacks * may execute concurrently, and listeners may execute in an order different from the one in which * they were registered.
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) -
android/guava-tests/test/com/google/common/util/concurrent/ServiceManagerTest.java
notifyStarted(); // We need to wait for the main thread to leave the ServiceManager.startAsync call // to // ensure that the thread running the failure callbacks is not the main thread. Uninterruptibles.awaitUninterruptibly(afterStarted); notifyFailed(new Exception("boom")); } }.start(); }
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Mon Oct 02 17:20:27 GMT 2023 - 23.2K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/ServiceManager.java
* across calls to multiple listeners. Specifically, a given listener will have its callbacks * invoked in the same order as the underlying service enters those states. Additionally, at most * one of the listener's callbacks will execute at once. However, multiple listeners' callbacks * may execute concurrently, and listeners may execute in an order different from the one in which * they were registered.
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Wed Dec 13 19:45:20 GMT 2023 - 30.5K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/ServiceManagerTest.java
notifyStarted(); // We need to wait for the main thread to leave the ServiceManager.startAsync call // to // ensure that the thread running the failure callbacks is not the main thread. Uninterruptibles.awaitUninterruptibly(afterStarted); notifyFailed(new Exception("boom")); } }.start(); }
Java - Registered: Fri Apr 12 12:43:09 GMT 2024 - Last Modified: Mon Oct 02 17:20:27 GMT 2023 - 23.9K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/AbstractService.java
import javax.annotation.CheckForNull; /** * Base class for implementing services that can handle {@link #doStart} and {@link #doStop} * requests, responding to them with {@link #notifyStarted()} and {@link #notifyStopped()} * callbacks. Its subclasses must manage threads manually; consider {@link * AbstractExecutionThreadService} if you need only a single execution thread. * * @author Jesse Wilson * @author Luke Sandberg * @since 1.0 */
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Fri May 12 18:32:03 GMT 2023 - 20.4K bytes - Viewed (0) -
guava-tests/test/com/google/common/base/OptionalTest.java
public void testOr_supplier_present() { assertEquals("a", Optional.of("a").or(Suppliers.ofInstance("fallback"))); } public void testOr_supplier_absent() { assertEquals("fallback", Optional.absent().or(Suppliers.ofInstance("fallback"))); } public void testOr_nullSupplier_absent() {
Java - Registered: Fri Apr 19 12:43:09 GMT 2024 - Last Modified: Wed Feb 21 18:32:41 GMT 2024 - 11.2K bytes - Viewed (0) -
guava-tests/test/com/google/common/eventbus/EventBusTest.java
* for bridge methods. */ public void testRegistrationWithBridgeMethod() { final AtomicInteger calls = new AtomicInteger(); bus.register( new Callback<String>() { @Subscribe @Override public void call(String s) { calls.incrementAndGet(); } }); bus.post("hello");
Java - Registered: Fri Apr 19 12:43:09 GMT 2024 - Last Modified: Wed Feb 21 18:32:41 GMT 2024 - 11.3K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/eventbus/EventBusTest.java
* for bridge methods. */ public void testRegistrationWithBridgeMethod() { final AtomicInteger calls = new AtomicInteger(); bus.register( new Callback<String>() { @Subscribe @Override public void call(String s) { calls.incrementAndGet(); } }); bus.post("hello");
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Wed Feb 21 18:32:41 GMT 2024 - 11.3K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/AbstractServiceTest.java
} /** * This tests for a bug where if {@link Service#stopAsync()} was called while the service was * {@link State#STARTING} more than once, the {@link Listener#stopping(State)} callback would get * called multiple times. */ public void testManualServiceStopMultipleTimesWhileStarting() throws Exception { ManualSwitchedService service = new ManualSwitchedService();
Java - Registered: Fri Apr 12 12:43:09 GMT 2024 - Last Modified: Wed Sep 06 17:04:31 GMT 2023 - 29.3K bytes - Viewed (0)