- Sort Score
- Result 10 results
- Languages All
Results 21 - 30 of 34 for Subscribers (0.16 sec)
-
android/guava/src/com/google/common/eventbus/SubscriberExceptionContext.java
* @param subscriber The source subscriber context. * @param subscriberMethod the subscribed method. */ SubscriberExceptionContext( EventBus eventBus, Object event, Object subscriber, Method subscriberMethod) { this.eventBus = checkNotNull(eventBus); this.event = checkNotNull(event); this.subscriber = checkNotNull(subscriber);
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-tests/test/com/google/common/eventbus/outside/BaseSubscriberFinderTest.java
import com.google.common.collect.Lists; import com.google.common.eventbus.Subscribe; import com.google.common.eventbus.outside.BaseSubscriberFinderTest.Subscriber; import java.util.List; public class BaseSubscriberFinderTest extends AbstractEventBusTest<Subscriber> { static class Subscriber { final List<Object> nonSubscriberEvents = Lists.newArrayList(); final List<Object> subscriberEvents = Lists.newArrayList();
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Tue Feb 08 21:35:40 GMT 2022 - 1.6K 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/SubscriberRegistryTest.java
ObjectSubscriber o1 = new ObjectSubscriber(); Iterator<Subscriber> empty = registry.getSubscribers(""); assertFalse(empty.hasNext()); empty = registry.getSubscribers(""); registry.register(s1); assertFalse(empty.hasNext()); Iterator<Subscriber> one = registry.getSubscribers(""); assertEquals(s1, one.next().target); assertFalse(one.hasNext());
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/BaseSubscriberFinderTest.java
import com.google.common.collect.Lists; import com.google.common.eventbus.Subscribe; import com.google.common.eventbus.outside.BaseSubscriberFinderTest.Subscriber; import java.util.List; public class BaseSubscriberFinderTest extends AbstractEventBusTest<Subscriber> { static class Subscriber { final List<Object> nonSubscriberEvents = Lists.newArrayList(); final List<Object> subscriberEvents = Lists.newArrayList();
Java - Registered: Fri Apr 19 12:43:09 GMT 2024 - Last Modified: Tue Feb 08 21:35:40 GMT 2022 - 1.6K 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() { return new SubscriberExceptionContext(eventBus, new Object(), this, subscriberMethod());
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) -
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() { return new SubscriberExceptionContext(eventBus, new Object(), this, subscriberMethod());
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) -
guava-tests/test/com/google/common/eventbus/SubscriberRegistryTest.java
ObjectSubscriber o1 = new ObjectSubscriber(); Iterator<Subscriber> empty = registry.getSubscribers(""); assertFalse(empty.hasNext()); empty = registry.getSubscribers(""); registry.register(s1); assertFalse(empty.hasNext()); Iterator<Subscriber> one = registry.getSubscribers(""); assertEquals(s1, one.next().target); assertFalse(one.hasNext());
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/src/com/google/common/eventbus/AllowConcurrentEvents.java
import java.lang.annotation.Retention; 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
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/Subscribe.java
import java.lang.annotation.ElementType; import java.lang.annotation.Retention; import java.lang.annotation.RetentionPolicy; import java.lang.annotation.Target; /** * Marks a method as an event subscriber. * * <p>The type of event will be indicated by the method's first (and only) parameter, which cannot * be primitive. If this annotation is applied to methods with zero parameters, or more than one
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Thu Apr 22 13:05:46 GMT 2021 - 1.5K bytes - Viewed (0)