getSubscriber - Code Search

guava-tests/test/com/google/common/eventbus/outside/AbstractNotAnnotatedInSuperclassTest.java

      overriddenAndAnnotatedInSubclassEvents.add(o);
    }
  }

  public void testOverriddenAndAnnotatedInSubclass() {
    assertThat(getSubscriber().overriddenAndAnnotatedInSubclassEvents).contains(EVENT);
  }

  public void testOverriddenInSubclassNowhereAnnotated() {
    assertThat(getSubscriber().overriddenInSubclassNowhereAnnotatedEvents).isEmpty();
  }

  @Override
  SubClass createSubscriber() {
    return new SubClass();

Java

- Registered: Fri Apr 19 12:43:09 GMT 2024

- Last Modified: Tue Feb 08 21:35:40 GMT 2022

- 2K bytes

- Viewed (0)

github.com/google/guava

android/guava-tests/test/com/google/common/eventbus/outside/AnnotatedAndAbstractInSuperclassTest.java

      overriddenInSubclassEvents.add(o);
    }
  }

  public void testOverriddenAndAnnotatedInSubclass() {
    assertThat(getSubscriber().overriddenAndAnnotatedInSubclassEvents).contains(EVENT);
  }

  public void testOverriddenNotAnnotatedInSubclass() {
    assertThat(getSubscriber().overriddenInSubclassEvents).contains(EVENT);
  }

  @Override
  SubClass createSubscriber() {
    return new SubClass();
  }

Java

- Registered: Fri May 03 12:43:13 GMT 2024

- Last Modified: Tue Feb 08 21:35:40 GMT 2022

- 2K bytes

- Viewed (0)

github.com/google/guava

android/guava-tests/test/com/google/common/eventbus/outside/AbstractEventBusTest.java

 * @author Louis Wasserman
 */
abstract class AbstractEventBusTest<H> extends TestCase {
  static final Object EVENT = new Object();

  abstract H createSubscriber();

  private @Nullable H subscriber;

  H getSubscriber() {
    return subscriber;
  }

  @Override
  protected void setUp() throws Exception {
    subscriber = createSubscriber();
    EventBus bus = new EventBus();
    bus.register(subscriber);

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)

github.com/google/guava

android/guava/src/com/google/common/eventbus/SubscriberExceptionContext.java

  /** @return The event object that caused the subscriber to throw. */
  public Object getEvent() {
    return event;
  }

  /** @return The object context that the subscriber was called on. */
  public Object getSubscriber() {
    return subscriber;
  }

  /** @return The subscribed method that threw the exception. */
  public Method getSubscriberMethod() {
    return subscriberMethod;
  }

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)

github.com/google/guava

guava-tests/test/com/google/common/eventbus/outside/AbstractEventBusTest.java

 * @author Louis Wasserman
 */
abstract class AbstractEventBusTest<H> extends TestCase {
  static final Object EVENT = new Object();

  abstract H createSubscriber();

  private @Nullable H subscriber;

  H getSubscriber() {
    return subscriber;
  }

  @Override
  protected void setUp() throws Exception {
    subscriber = createSubscriber();
    EventBus bus = new EventBus();
    bus.register(subscriber);

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)

github.com/google/guava

guava-tests/test/com/google/common/eventbus/EventBusTest.java

    assertEquals("Event should be available.", EVENT, handler.context.getEvent());
    assertEquals("Subscriber should be available.", subscriber, handler.context.getSubscriber());
    assertEquals(
        "Method should be available.",
        subscriber.getClass().getMethod("throwExceptionOn", String.class),
        handler.context.getSubscriberMethod());
  }

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)

github.com/google/guava

android/guava-tests/test/com/google/common/eventbus/EventBusTest.java

    assertEquals("Event should be available.", EVENT, handler.context.getEvent());
    assertEquals("Subscriber should be available.", subscriber, handler.context.getSubscriber());
    assertEquals(
        "Method should be available.",
        subscriber.getClass().getMethod("throwExceptionOn", String.class),
        handler.context.getSubscriberMethod());
  }

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)

github.com/google/guava

android/guava/src/com/google/common/eventbus/EventBus.java

          + method.getName()
          + '('
          + method.getParameterTypes()[0].getName()
          + ')'
          + " on subscriber "
          + context.getSubscriber()
          + " when dispatching event: "
          + context.getEvent();
    }
  }

Java

- Registered: Fri Apr 26 12:43:10 GMT 2024

- Last Modified: Wed Aug 25 16:37:57 GMT 2021

- 12.8K bytes

- Viewed (0)

github.com/google/guava

android/guava-tests/test/com/google/common/eventbus/SubscriberRegistryTest.java

    assertEquals(1, Iterators.size(registry.getSubscribers(1)));

    registry.register(new IntegerSubscriber());
    assertEquals(3, Iterators.size(registry.getSubscribers("")));
    assertEquals(1, Iterators.size(registry.getSubscribers(new Object())));
    assertEquals(2, Iterators.size(registry.getSubscribers(1)));
  }

  public void testGetSubscribers_returnsImmutableSnapshot() {

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)

github.com/google/guava

guava-tests/test/com/google/common/eventbus/SubscriberRegistryTest.java

    assertEquals(1, Iterators.size(registry.getSubscribers(1)));

    registry.register(new IntegerSubscriber());
    assertEquals(3, Iterators.size(registry.getSubscribers("")));
    assertEquals(1, Iterators.size(registry.getSubscribers(new Object())));
    assertEquals(2, Iterators.size(registry.getSubscribers(1)));
  }

  public void testGetSubscribers_returnsImmutableSnapshot() {

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)

Search Options