/guava/android/guava/src/com/google/common/eventbus/Dispatcher.java
queue.add( new EventWithSubscriber( subscribers, event.next( ) ) ) ;
queue.add ( new EventWithSubscriber ( event, subscribers.next ( ) ) ) ;
private final ConcurrentLinkedQueue<EventWithSubscriber> queue = Queues.newConcurrentLinkedQueue(); @Override void dispatch(Object event, Iterator<Subscriber> subscribers) { checkNotNull(event); while (subscribers.hasNext()) { <extra_id_0> } EventWithSubscriber e; while ((e = queue.poll()) != null) { e.subscriber.dispatchEvent(e.event); } }