- Sort Score
- Result 10 results
- Languages All
Results 21 - 30 of 43 for Subscriber (0.34 sec)
-
guava-tests/test/com/google/common/eventbus/outside/AbstractEventBusTest.java
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 protected void tearDown() throws Exception { subscriber = null; }
Java - Registered: Fri Apr 19 12:43:09 GMT 2024 - Last Modified: Mon Apr 17 15:19:38 GMT 2023 - 1.6K bytes - Viewed (0) -
android/guava/src/com/google/common/eventbus/DeadEvent.java
import static com.google.common.base.Preconditions.checkNotNull; import com.google.common.base.MoreObjects; /** * Wraps an event that was posted, but which had no subscribers and thus could not be delivered. * * <p>Registering a DeadEvent subscriber is useful for debugging or logging, as it can detect * misconfigurations in a system's event distribution. * * @author Cliff Biffle * @since 10.0 */
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Thu Apr 22 13:05:46 GMT 2021 - 2.1K bytes - Viewed (0) -
guava-tests/test/com/google/common/eventbus/outside/DeepInterfaceTest.java
import com.google.common.eventbus.Subscribe; import com.google.common.eventbus.outside.DeepInterfaceTest.SubscriberClass; import java.util.List; public class DeepInterfaceTest extends AbstractEventBusTest<SubscriberClass> { interface Interface1 { @Subscribe void annotatedIn1(Object o); @Subscribe void annotatedIn1And2(Object o); @Subscribe void annotatedIn1And2AndClass(Object o);
Java - Registered: Fri Apr 19 12:43:09 GMT 2024 - Last Modified: Tue Feb 08 21:35:40 GMT 2022 - 4.2K bytes - Viewed (0) -
guava-tests/test/com/google/common/eventbus/ReentrantEventsTest.java
boolean ready = true; List<Object> eventsReceived = Lists.newArrayList(); @Subscribe public void listenForStrings(String event) { eventsReceived.add(event); ready = false; try { bus.post(SECOND); } finally { ready = true; } } @Subscribe public void listenForDoubles(Double event) {
Java - Registered: Fri Apr 19 12:43:09 GMT 2024 - Last Modified: Mon Dec 04 17:37:03 GMT 2017 - 2.5K bytes - Viewed (0) -
guava-tests/test/com/google/common/eventbus/outside/OutsideEventBusTest.java
* limitations under the License. */ package com.google.common.eventbus.outside; import com.google.common.eventbus.EventBus; import com.google.common.eventbus.Subscribe; import java.util.concurrent.atomic.AtomicInteger; import java.util.concurrent.atomic.AtomicReference; import junit.framework.TestCase; /** * Test cases for {@code EventBus} that must not be in the same package. *
Java - Registered: Fri Apr 19 12:43:09 GMT 2024 - Last Modified: Mon Dec 04 17:37:03 GMT 2017 - 1.8K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/eventbus/outside/DeepInterfaceTest.java
import com.google.common.eventbus.Subscribe; import com.google.common.eventbus.outside.DeepInterfaceTest.SubscriberClass; import java.util.List; public class DeepInterfaceTest extends AbstractEventBusTest<SubscriberClass> { interface Interface1 { @Subscribe void annotatedIn1(Object o); @Subscribe void annotatedIn1And2(Object o); @Subscribe void annotatedIn1And2AndClass(Object o);
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Tue Feb 08 21:35:40 GMT 2022 - 4.2K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/eventbus/ReentrantEventsTest.java
boolean ready = true; List<Object> eventsReceived = Lists.newArrayList(); @Subscribe public void listenForStrings(String event) { eventsReceived.add(event); ready = false; try { bus.post(SECOND); } finally { ready = true; } } @Subscribe public void listenForDoubles(Double event) {
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Tue May 15 20:25:06 GMT 2018 - 2.5K bytes - Viewed (0) -
android/guava-tests/benchmark/com/google/common/eventbus/EventBusBenchmark.java
eventBus.register(this); } @Benchmark void postStrings(int reps) { for (int i = 0; i < reps; i++) { eventBus.post("hello there"); } } @Subscribe public void handleStrings(String string) { // Nothing to do here. }
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Tue May 15 20:25:06 GMT 2018 - 1.2K bytes - Viewed (0) -
android/guava/src/com/google/common/eventbus/SubscriberExceptionHandler.java
* the License. */ package com.google.common.eventbus; /** * Handler for exceptions thrown by event subscribers. * * @since 16.0 */ @ElementTypesAreNonnullByDefault public interface SubscriberExceptionHandler { /** Handles exceptions thrown by subscribers. */ void handleException(Throwable exception, SubscriberExceptionContext context);
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Thu Apr 22 13:05:46 GMT 2021 - 928 bytes - Viewed (0) -
android/guava-tests/test/com/google/common/eventbus/StringCatcher.java
*/ public class StringCatcher { private List<String> events = Lists.newArrayList(); @Subscribe public void hereHaveAString(@Nullable String string) { events.add(string); } public void methodWithoutAnnotation(@Nullable String string) { Assert.fail("Event bus must not call methods without @Subscribe!"); } public List<String> getEvents() { return events; }
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Thu Apr 06 12:56:11 GMT 2023 - 1.4K bytes - Viewed (0)