- Sort Score
- Result 10 results
- Languages All
Results 21 - 30 of 101 for subscribed (0.41 sec)
-
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/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) -
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) -
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 Apr 19 12:43:09 GMT 2024 - Last Modified: Wed May 16 22:49:59 GMT 2018 - 1.9K bytes - Viewed (0) -
android/guava/src/com/google/common/eventbus/AllowConcurrentEvents.java
import java.lang.annotation.RetentionPolicy; import java.lang.annotation.Target; /** * Marks an event subscriber method as being thread-safe. This annotation indicates that EventBus * may invoke the event subscriber simultaneously from multiple threads. * * <p>This does not mark the method, and so should be used in combination with {@link Subscribe}. * * @author Cliff Biffle * @since 10.0 */ @Retention(RetentionPolicy.RUNTIME)
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Thu Apr 22 13:05:46 GMT 2021 - 1.2K 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) -
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-tests/test/com/google/common/eventbus/outside/AnnotatedNotAbstractInSuperclassTest.java
@Subscribe public void notOverriddenInSubclass(Object o) { notOverriddenInSubclassEvents.add(o); } @Subscribe public void overriddenNotAnnotatedInSubclass(Object o) { overriddenNotAnnotatedInSubclassEvents.add(o); } @Subscribe public void overriddenAndAnnotatedInSubclass(Object o) {
Java - Registered: Fri May 03 12:43:13 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
import com.google.common.eventbus.Subscribe; import com.google.common.eventbus.outside.AnnotatedAndAbstractInSuperclassTest.SubClass; import java.util.List; public class AnnotatedAndAbstractInSuperclassTest extends AbstractEventBusTest<SubClass> { abstract static class SuperClass { @Subscribe public abstract void overriddenAndAnnotatedInSubclass(Object o); @Subscribe
Java - Registered: Fri Apr 19 12:43:09 GMT 2024 - Last Modified: Tue Feb 08 21:35:40 GMT 2022 - 2K bytes - Viewed (0) -
maven-core/src/test/resources/org/apache/maven/extension/test-extension-repo/org/codehaus/plexus/plexus/1.0.9/plexus-1.0.9.pom
<name>Plexus User List</name> <subscribe>http://xircles.codehaus.org/manage_email/user%40plexus.codehaus.org</subscribe> <unsubscribe>http://xircles.codehaus.org/manage_email/user%40plexus.codehaus.org</unsubscribe> <archive>http://archive.plexus.codehaus.org/user</archive> </mailingList> <mailingList> <name>Plexus Developer List</name>
Plain Text - Registered: Sun Mar 31 03:35:09 GMT 2024 - Last Modified: Thu Dec 24 18:09:10 GMT 2020 - 7.5K bytes - Viewed (0)