如何在volley success MVVM架构上通知UI

Question

// save data to api

checkInViewModel.updateEventPersonEntity(eventPersonsEntity);

public void updateEventPersonEntity(EventPersonsEntity eventPersonsEntity) {
    mRepository.updateEventPersonEntity(eventPersonsEntity);
}

apprepository.java类

    public void updateEventPersonEntity(EventPersonsEntity eventPersonsEntity) {
        executor.execute(() -> {
           // mDb.eventPersonsDao().update(eventPersonsEntity);

            if (isNetworkAvailable(context)) {
                post_updateEventPersonEntity(eventPersonsEntity);
            }
        });
    }

private void post_updateEventPersonEntity(EventPersonsEntity eventPersonsEntity) {

        Map<String, Object> params = new HashMap<>();
        params.put("EventPersonId", eventPersonsEntity.getEventPersonId());
        params.put("EventId", eventPersonsEntity.getEventId());
        params.put("PersonId", eventPersonsEntity.getPersonId());
        params.put("CashStart", parseDoubleToGerman(eventPersonsEntity.getCashStart()));
        params.put("CashEnd", parseDoubleToGerman(eventPersonsEntity.getCashEnd()));
        params.put("StartingTime", String.valueOf(eventPersonsEntity.getStartingTime()));
        params.put("EndingTime", String.valueOf(eventPersonsEntity.getEndingTime()));
        params.put("isChekcedIn", eventPersonsEntity.getIsCheckedIn());
        params.put("isChekcedOut", eventPersonsEntity.getIsCheckedOut());

        JSONObject objRegData = new JSONObject(params);

        String eventPersonApi = APP_URL.EVENT_PERSONS_API + eventPersonsEntity.getEventPersonId();
        RequestQueueSingleton.getInstance(context).objectRequest(eventPersonApi, Request.Method.PUT, this::onSuccess_updateEventPersonEntity, this::onError, objRegData);

    }

    private void onError(VolleyError error) {

        Log.d(APP_REPOSITORY_TAG, "requestError: " + error);
    }

    private void onSuccess_updateEventPersonEntity(JSONObject jsonObject) {

        // notify ui

    }

Answer 1

您可以像在存储库中为成功响应逻辑所做的那样执行此操作。只需创建新的回调接口：

interface OnEventUpdatedListener{
    void eventUpdated();
}

然后，将您的方法更新为如下所示，将侦听器传递给执行该工作的实际方法：

    public void updateEventPersonEntity(EventPersonsEntity eventPersonsEntity, OnEventUpdatedListener listener) {
    mRepository.updateEventPersonEntity(eventPersonsEntity, listener);
}

在您的：

            if (isNetworkAvailable(context)) {
            post_updateEventPersonEntity(eventPersonsEntity, listener);
        }

    private void onSuccess_updateEventPersonEntity(JSONObject jsonObject) {

    listener.eventUpdated();

}

        updateEventPersonEntity(null, new OnEventUpdatedListener() {
        @Override
        public void EventUpdated() {
            // Do your logic here
        }
    });