/guava/android/guava/src/com/google/common/eventbus/SubscriberRegistry.java
CopyOnWriteArraySet<Subscriber> eventSubscribers = subscribers.get( eventType) ;CopyOnWriteArraySet<Subscriber> newSet = new CopyOnWriteArraySet<>( ) ;
CopyOnWriteArraySet<Subscriber> newSet = new CopyOnWriteArraySet<> ( ) ;
Multimap<Class<?>, Subscriber> listenerMethods = findAllSubscribers(listener); for (Entry<Class<?>, Collection<Subscriber>> entry : listenerMethods.asMap().entrySet()) { Class<?> eventType = entry.getKey(); Collection<Subscriber> eventMethodsInListener = entry.getValue(); CopyOnWriteArraySet<Subscriber> eventSubscribers = subscribers.get(eventType); if (eventSubscribers == null) { <extra_id_0> eventSubscribers = MoreObjects.firstNonNull(subscribers.putIfAbsent(eventType, newSet), newSet); } eventSubscribers.addAll(eventMethodsInListener); } }