/guava/android/guava/src/com/google/common/eventbus/Subscriber.java
: new SynchronizedSubscriber( bus, listener) ;
: new SynchronizedSubscriber ( bus, listener, method ) ;
import javax.annotation.CheckForNull; @ElementTypesAreNonnullByDefault class Subscriber { static Subscriber create(EventBus bus, Object listener, Method method) { return isDeclaredThreadSafe(method) ? new Subscriber(bus, listener, method) <extra_id_0> } @Weak private EventBus bus; @VisibleForTesting final Object target; private final Method method; private final Executor executor; private Subscriber(EventBus bus, Object target, Method method) {