- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 12 for Subscribe (0.18 sec)
-
guava-tests/test/com/google/common/eventbus/EventBusTest.java
new RuntimeException("but culottes have a tendancy to ride up!"); final Object subscriber = new Object() { @Subscribe public void throwExceptionOn(String message) { throw exception; } }; eventBus.register(subscriber); eventBus.post(EVENT); assertEquals("Cause should be available.", exception, handler.exception);
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
new RuntimeException("but culottes have a tendancy to ride up!"); final Object subscriber = new Object() { @Subscribe public void throwExceptionOn(String message) { throw exception; } }; eventBus.register(subscriber); eventBus.post(EVENT); assertEquals("Cause should be available.", exception, handler.exception);
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/eventbus/SubscriberRegistryTest.java
Iterator<Subscriber> two = registry.getSubscribers(""); assertEquals(s1, two.next().target); assertEquals(o1, two.next().target); assertFalse(two.hasNext()); } public static class StringSubscriber { @Subscribe public void handle(String s) {} } public static class IntegerSubscriber { @Subscribe public void handle(Integer i) {} }
Java - Registered: Fri Apr 19 12:43:09 GMT 2024 - Last Modified: Wed Sep 06 17:04:31 GMT 2023 - 5.7K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/eventbus/SubscriberTest.java
} public void testCreate() { Subscriber s1 = Subscriber.create(bus, this, getTestSubscriberMethod("recordingMethod")); assertThat(s1).isInstanceOf(Subscriber.SynchronizedSubscriber.class); // a thread-safe method should not create a synchronized subscriber Subscriber s2 = Subscriber.create(bus, this, getTestSubscriberMethod("threadSafeMethod")); assertThat(s2).isNotInstanceOf(Subscriber.SynchronizedSubscriber.class); }
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Wed Sep 06 17:04:31 GMT 2023 - 4.8K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/eventbus/SubscriberRegistryTest.java
Iterator<Subscriber> two = registry.getSubscribers(""); assertEquals(s1, two.next().target); assertEquals(o1, two.next().target); assertFalse(two.hasNext()); } public static class StringSubscriber { @Subscribe public void handle(String s) {} } public static class IntegerSubscriber { @Subscribe public void handle(Integer i) {} }
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Wed Sep 06 17:04:31 GMT 2023 - 5.7K 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) -
guava-tests/test/com/google/common/eventbus/SubscriberTest.java
} public void testCreate() { Subscriber s1 = Subscriber.create(bus, this, getTestSubscriberMethod("recordingMethod")); assertThat(s1).isInstanceOf(Subscriber.SynchronizedSubscriber.class); // a thread-safe method should not create a synchronized subscriber Subscriber s2 = Subscriber.create(bus, this, getTestSubscriberMethod("threadSafeMethod")); assertThat(s2).isNotInstanceOf(Subscriber.SynchronizedSubscriber.class); }
Java - Registered: Fri Apr 19 12:43:09 GMT 2024 - Last Modified: Wed Sep 06 17:04:31 GMT 2023 - 4.8K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/eventbus/PackageSanityTests.java
} private static class DummySubscriber { private final EventBus eventBus = new EventBus(); @Subscribe public void handle(@Nullable Object anything) {} Subscriber toSubscriber() throws Exception { return Subscriber.create(eventBus, this, subscriberMethod()); } SubscriberExceptionContext toContext() {
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Thu Apr 06 12:56:11 GMT 2023 - 1.9K bytes - Viewed (0) -
android/guava/src/com/google/common/eventbus/package-info.java
* the License. */ /** * <a href="https://guava.dev/EventBus">Discouraged</a> in favor of dependency injection and * concurrency frameworks, EventBus allows publish-subscribe-style communication. * * <p>See the Guava User Guide article on <a * href="https://github.com/google/guava/wiki/EventBusExplained">{@code EventBus}</a>. */ @CheckReturnValue @ParametersAreNonnullByDefault
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Fri Jun 23 19:57:03 GMT 2023 - 1.1K bytes - Viewed (0) -
android/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 May 03 12:43:13 GMT 2024 - Last Modified: Mon Apr 17 15:19:38 GMT 2023 - 1.6K bytes - Viewed (0)