Различать несколько событий на одном и том же Eventbus

Question

Я создал приложение с использованием шаблона MVP, нашел ссылку на учебник и решил внедрить его в свое приложение, чтобы фрагменты могли взаимодействовать с их действиями. Я переместил реализацию Eventbus в соответствующий ведущий активности и ведущий фрагмента, чтобы все еще использовать шаблон MVP. Теперь я столкнулся с новой проблемой: один из моих фрагментов должен изменить две вещи в параметрах активности (связанные с панелью инструментов и отображаемым ImageView). Можно ли как-то отличить, от какого обратного вызова есть функция accept?

Класс RxBus

public final class RxBus {

    private static SparseArray<PublishSubject<Object>> sSubjectMap = new SparseArray<>();
    private static Map<Object, CompositeDisposable> sSubscriptionsMap = new HashMap<>();

    public static final int CHANGE_APP_BAR_LAYOUT = 0;
    public static final int CHANGE_POSTER_IMAGE = 1;

    @IntDef({CHANGE_APP_BAR_LAYOUT, CHANGE_POSTER_IMAGE})
    @interface Subject {
    }

    private RxBus() {
        // hidden constructor
    }

    /**
     * Get the subject or create it if it's not already in memory.
     */
    @NonNull
    private static PublishSubject<Object> getSubject(@Subject int subjectCode) {
        PublishSubject<Object> subject = sSubjectMap.get(subjectCode);
        if (subject == null) {
            subject = PublishSubject.create();
            subject.subscribeOn(AndroidSchedulers.mainThread());
            sSubjectMap.put(subjectCode, subject);
        }

        return subject;
    }

    /**
     * Get the CompositeDisposable or create it if it's not already in memory.
     */
    @NonNull
    private static CompositeDisposable getCompositeDisposable(@NonNull Object object) {
        CompositeDisposable compositeDisposable = sSubscriptionsMap.get(object);
        if (compositeDisposable == null) {
            compositeDisposable = new CompositeDisposable();
            sSubscriptionsMap.put(object, compositeDisposable);
        }

        return compositeDisposable;
    }

    /**
     * Subscribe to the specified subject and listen for updates on that subject. Pass in an object to associate
     * your registration with, so that you can unsubscribe later.
     * <br/><br/>
     * <b>Note:</b> Make sure to call {@link RxBus#unregister(Object)} to avoid memory leaks.
     */
    public static void subscribe(@Subject int subject, @NonNull Object lifecycle, @NonNull Consumer<Object> action) {
        Disposable disposable = getSubject(subject).subscribe(action);
        getCompositeDisposable(lifecycle).add(disposable);
    }

    /**
     * Unregisters this object from the bus, removing all subscriptions.
     * This should be called when the object is going to go out of memory.
     */
    public static void unSubscribe(@NonNull Object lifecycle) {
        //We have to remove the composition from the map, because once you dispose it can't be used anymore
        CompositeDisposable compositeDisposable = sSubscriptionsMap.remove(lifecycle);
        if (compositeDisposable != null) {
            compositeDisposable.dispose();
        }
    }

    /**
     * Publish an object to the specified subject for all subscribers of that subject.
     */
    public static void publish(@Subject int subject, @NonNull Object message) {
        getSubject(subject).onNext(message);
    }
}

Класс MainPresenter

public class MainPresenter extends BasePresenter<MainView> implements Observer<ConfigurationResponse>,Consumer<Object>
{
     ...
     @Override
     public void accept(Object o) throws Exception {
          //here is the problem how can I know if I should call to changeAppBar or change Image url?
     }

Класс ClientPresenter

public class ClientPresenter extends BasePresenter<SeriesSpecsView>
{
    ...

    //I'm calling to those function withing the fragment when the user click on the ui
    public void setPosterUrl(String posterUrl)
    {
        RxBus.publish(RxBus.CHANGE_POSTER_IMAGE,posterUrl);
    }

    public void setAppBarLayoutParams(boolean collapse)
    {
        RxBus.publish(RxBus.CHANGE_APP_BAR_LAYOUT,collapse);
    }
}

Я нашел два решения этой проблемы:

1) проверить объект, вызвав функцию instanceof, не очень эффективно, и если мне нужно будет отправить один и тот же тип информации между двумя событиями?

2) Добавьте еще один Evenbus, но я не думаю, что логично иметь отдельную шину событий для каждого события, для которого вы хотите иметь обратный вызов своей деятельности.

Спасибо за вашу помощь

ОБНОВИТЬ

Я столкнулся с другой проблемой (или, по крайней мере, потенциально проблемой). Я добавил SwipeRefreshLayout, чтобы обернуть мой контент (который представляет собой framelayout, каждый мой фрагмент будет отображаться в этом контейнере). Моей главной причиной было сделать единый интерфейс между действием и всеми фрагментами. Допустим, у вас нет сетевого подключения. Я покажу пользователю сообщение, чтобы провести пальцем вниз, чтобы попытаться обновить текущий фрагмент. До сих пор я делал это, добавляя SwipeRefreshLayout к каждому фрагменту, который у меня есть. Это в основном один и тот же код, и я подумал объединить весь код в одном месте в упражнении. Я хотел бы использовать EventBus, но, насколько я понимаю, мне нужно подписать все фрагменты на "событие" onRefresh. Как я могу отправить событие на соответствующий фрагмент?

Answer 1

Я использую RxBus для передачи глобальных событий. Вы также можете использовать это по-своему.

class RxBus {
    private val  busSubject: Subject<ActionEvent<out Any>> =
            PublishSubject.create()

    fun  register( onNext:
    Consumer<ActionEvent<out Any>>):Disposable{
        return busSubject
                .observeOn(AndroidSchedulers.mainThread())
                .subscribe(onNext)

    }


    fun post(event: ActionEvent<out Any>) {
        busSubject.onNext(event)
    }

}

open class ActionEvent<T>(val action: ActionEnum
                     , val event: T) {


}

Вы можете использовать String вместо ActionEnum, который является просто классом enum

Когда вы публикуете что-то,

getRxBus()?.post(ActionEvent(ActionEnum.CHANGE_APP_BAR_LAYOUT,collapse))

Когда вы хотите подписаться,

val disposable = rxBus.subscribe(Consumer{...})

Не забудьте избавиться от утилизации на уничтожение.