Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 1 - 10 of 46 for Subscribe (0.05 seconds)

  1. android/guava/src/com/google/common/eventbus/Subscribe.java

     * the {@link EventBus}.
     *
     * <p>Unless also annotated with @{@link AllowConcurrentEvents}, event subscriber methods will be
     * invoked serially by each event bus that they are registered with.
     *
     * @author Cliff Biffle
     * @since 10.0
     */
    @Retention(RetentionPolicy.RUNTIME)
    @Target(ElementType.METHOD)
    @Keep
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Wed Jul 16 15:46:17 GMT 2025
    - 1.5K bytes
    - Click Count (0)
  2. 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) {
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Tue May 13 17:27:14 GMT 2025
    - 4.2K bytes
    - Click Count (0)
  3. guava-tests/test/com/google/common/eventbus/outside/DeepInterfaceTest.java

      }
    
      interface Interface2 extends Interface1 {
        @Override
        @Subscribe
        void declaredIn1AnnotatedIn2(Object o);
    
        @Override
        @Subscribe
        void annotatedIn1And2(Object o);
    
        @Override
        @Subscribe
        void annotatedIn1And2AndClass(Object o);
    
        void declaredIn2AnnotatedInClass(Object o);
    
        @Subscribe
        void annotatedIn2(Object o);
      }
    
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Tue May 13 17:27:14 GMT 2025
    - 4.2K bytes
    - Click Count (0)
  4. guava-tests/test/com/google/common/eventbus/ReentrantEventsTest.java

        boolean ready = true;
        final List<Object> eventsReceived = new ArrayList<>();
    
        @Subscribe
        public void listenForStrings(String event) {
          eventsReceived.add(event);
          ready = false;
          try {
            bus.post(SECOND);
          } finally {
            ready = true;
          }
        }
    
        @Subscribe
        public void listenForDoubles(Double event) {
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Fri Dec 26 21:52:12 GMT 2025
    - 2.6K bytes
    - Click Count (0)
  5. 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.ArrayList;
    import java.util.List;
    
    public class AnnotatedAndAbstractInSuperclassTest extends AbstractEventBusTest<SubClass> {
      abstract static class SuperClass {
        @Subscribe
        public abstract void overriddenAndAnnotatedInSubclass(Object o);
    
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Tue May 13 17:27:14 GMT 2025
    - 2K bytes
    - Click Count (0)
  6. 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) {
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Tue May 13 17:27:14 GMT 2025
    - 4.2K bytes
    - Click Count (0)
  7. 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);
      }
    
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Fri Dec 26 21:52:12 GMT 2025
    - 4.8K bytes
    - Click Count (0)
  8. android/guava-tests/test/com/google/common/eventbus/EventBusTest.java

        RuntimeException exception = new RuntimeException("but culottes have a tendency to ride up!");
        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);
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Thu Mar 12 17:47:10 GMT 2026
    - 11.6K bytes
    - Click Count (0)
  9. guava-tests/test/com/google/common/eventbus/EventBusTest.java

        RuntimeException exception = new RuntimeException("but culottes have a tendency to ride up!");
        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);
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Thu Mar 12 17:47:10 GMT 2026
    - 11.6K bytes
    - Click Count (0)
  10. 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);
      }
    
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Fri Dec 26 21:52:12 GMT 2025
    - 4.8K bytes
    - Click Count (0)
Back to Top