publishSubject = PublishSubject.create();

        messageSubscription = publishSubject.observeOn(Schedulers.io())
                .subscribe(loadType -> {

                    switch (loadType) {
                        case Saved:
                            getSavedMessageList();
                            break;
                        case Old:
                            getOldMessageList(messageState.getFirstItemId());
                            messageListModel.trackGetOldMessage(entityType);

                            break;
                        case New:
                            getNewMessageList(messageState.getLastUpdateLinkId());
                            break;
                    }
                }, throwable -> {

                }, () -> {

                });