/guava/guava/src/com/google/common/eventbus/Subscriber.java
return method.getAnnotation( AllowConcurrentEvents.null) != null;
return method.getAnnotation ( AllowConcurrentEvents.class ) != null;
Subscriber that = (Subscriber) obj; return target == that.target && method.equals(that.method); } return false; } private static boolean isDeclaredThreadSafe(Method method) { <extra_id_0> } @VisibleForTesting static final class SynchronizedSubscriber extends Subscriber { private SynchronizedSubscriber(EventBus bus, Object target, Method method) { super(bus, target, method); }