- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 60 for Nevett (0.19 sec)
-
android/guava/src/com/google/common/eventbus/SubscriberExceptionContext.java
public class SubscriberExceptionContext { private final EventBus eventBus; private final Object event; private final Object subscriber; private final Method subscriberMethod; /** * @param eventBus The {@link EventBus} that handled the event and the subscriber. Useful for * broadcasting a new event based on the error. * @param event The event object that caused the subscriber to throw. * @param subscriber The source subscriber context.
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Thu Apr 22 13:05:46 GMT 2021 - 2.2K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/AbstractService.java
terminatedEvent(NEW); private static final ListenerCallQueue.Event<Listener> TERMINATED_FROM_STARTING_EVENT = terminatedEvent(STARTING); private static final ListenerCallQueue.Event<Listener> TERMINATED_FROM_RUNNING_EVENT = terminatedEvent(RUNNING); private static final ListenerCallQueue.Event<Listener> TERMINATED_FROM_STOPPING_EVENT =
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) -
android/guava/src/com/google/common/eventbus/AsyncEventBus.java
* * @param identifier short name for the bus, for logging purposes. * @param executor Executor to use to dispatch events. It is the caller's responsibility to shut * down the executor after the last event has been posted to this event bus. */ public AsyncEventBus(String identifier, Executor executor) { super(identifier, executor, Dispatcher.legacyAsync(), LoggingHandler.INSTANCE); } /**
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Thu Apr 22 13:05:46 GMT 2021 - 2.5K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/eventbus/outside/AnnotatedNotAbstractInSuperclassTest.java
} public void testOverriddenNotAnnotatedInSubclass() { assertThat(getSubscriber().overriddenNotAnnotatedInSubclassEvents).contains(EVENT); } public void testDifferentlyOverriddenNotAnnotatedInSubclass() { assertThat(getSubscriber().differentlyOverriddenNotAnnotatedInSubclassGoodEvents) .contains(EVENT);
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Tue Feb 08 21:35:40 GMT 2022 - 4.1K bytes - Viewed (0) -
guava-tests/test/com/google/common/eventbus/outside/AnnotatedAndAbstractInSuperclassTest.java
} } public void testOverriddenAndAnnotatedInSubclass() { assertThat(getSubscriber().overriddenAndAnnotatedInSubclassEvents).contains(EVENT); } public void testOverriddenNotAnnotatedInSubclass() { assertThat(getSubscriber().overriddenInSubclassEvents).contains(EVENT); } @Override SubClass createSubscriber() { return new SubClass(); }
Java - Registered: Fri Apr 19 12:43:09 GMT 2024 - Last Modified: Tue Feb 08 21:35:40 GMT 2022 - 2K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/eventbus/outside/AbstractEventBusTest.java
static final Object EVENT = new Object(); abstract H createSubscriber(); private @Nullable H subscriber; H getSubscriber() { return subscriber; } @Override protected void setUp() throws Exception { subscriber = createSubscriber(); EventBus bus = new EventBus(); bus.register(subscriber); bus.post(EVENT); } @Override
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Mon Apr 17 15:19:38 GMT 2023 - 1.6K bytes - Viewed (0) -
futures/failureaccess/src/com/google/common/util/concurrent/internal/InternalFutureFailureAccess.java
* </ul> * * <p>This method is {@code protected} so that classes like {@code * com.google.common.util.concurrent.SettableFuture} do not expose it to their users as an * instance method. In the unlikely event that you need to call this method, call {@link * InternalFutures#tryInternalFastPathGetFailure(InternalFutureFailureAccess)}. */ protected abstract Throwable tryInternalFastPathGetFailure();
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Tue Apr 04 09:45:04 GMT 2023 - 2.3K bytes - Viewed (0) -
guava-testlib/src/com/google/common/testing/GcFinalization.java
* specified the JVM flag {@code -XX:+DisableExplicitGC}. But in practice, it works very well for * ordinary tests. * * <p>Failure of the expected event to occur within an implementation-defined "reasonable" time * period or an interrupt while waiting for the expected event will result in a {@link * RuntimeException}. * * <p>Here's an example that tests a {@code finalize} method: * * <pre>{@code
Java - Registered: Fri Apr 19 12:43:09 GMT 2024 - Last Modified: Thu Feb 22 17:40:56 GMT 2024 - 11.6K bytes - Viewed (0) -
android/guava/src/com/google/common/collect/Ordering.java
Platform.tryWeakKeys(new MapMaker()).makeMap(); private Integer getUid(Object obj) { Integer uid = uids.get(obj); if (uid == null) { // One or more integer values could be skipped in the event of a race // to generate a UID for the same object from multiple threads, but // that shouldn't be a problem. uid = counter.getAndIncrement(); Integer alreadySet = uids.putIfAbsent(obj, uid);
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Wed Apr 24 19:38:27 GMT 2024 - 39.4K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/AbstractScheduledService.java
// is called within doStart() so we know that the service cannot terminate or fail concurrently // with adding this listener so it is impossible to miss an event that we are interested in. addListener( new Listener() { @Override public void terminated(State from) { executor.shutdown(); } @Override
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Wed Dec 13 19:45:20 GMT 2023 - 25.8K bytes - Viewed (0)