code: static Subscriber create(EventBus bus, Object listener, Method method) {
      return isDeclaredThreadSafe(method)
          ? new Subscriber(bus, listener, method)
          : new SynchronizedSubscriber(bus, listener, method);
    }
docs: Creates a {@code Subscriber} for {@code method} on {@code listener}.