Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 4 of 4 for getSubscribers (0.18 sec)

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

      }
    
      /**
       * Gets an iterator representing an immutable snapshot of all subscribers to the given event at
       * the time this method is called.
       */
      Iterator<Subscriber> getSubscribers(Object event) {
        ImmutableSet<Class<?>> eventTypes = flattenHierarchy(event.getClass());
    
        List<Iterator<Subscriber>> subscriberIterators =
            Lists.newArrayListWithCapacity(eventTypes.size());
    
    Java
    - Registered: Fri Apr 26 12:43:10 GMT 2024
    - Last Modified: Thu Apr 22 13:05:46 GMT 2021
    - 10.5K bytes
    - Viewed (0)
  2. android/guava/src/com/google/common/eventbus/EventBus.java

       * already a {@link DeadEvent}, it will be wrapped in a DeadEvent and reposted.
       *
       * @param event event to post.
       */
      public void post(Object event) {
        Iterator<Subscriber> eventSubscribers = subscribers.getSubscribers(event);
        if (eventSubscribers.hasNext()) {
          dispatcher.dispatch(event, eventSubscribers);
        } else if (!(event instanceof DeadEvent)) {
          // the event had no subscribers and was not itself a DeadEvent
    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)
  3. 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)
  4. 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)
Back to top