Recyclerview с использованием liveata не обновляется после изменения данных. Только после того, как я поверну экран

Question

У меня есть приложение погоды, которое позволяет пользователю сохранять местоположения (хранящиеся в БД комнаты локально) и отображать погоду в указанных местоположениях. Когда пользователь добавляет город в базу данных, я выполняю вызов API погоды, затем добавляю город в базу данных с необходимой информацией.

public class InsertSingleCityWorker extends Worker {

private MyCitiesDatabase citiesDatabase;
private String nickname;
private int zip;

private static final String TAG = "APICallsWorker";


public InsertSingleCityWorker(@NonNull Context context, @NonNull WorkerParameters workerParams) {
    super(context, workerParams);
    citiesDatabase = MyCitiesDatabase.getInstance(getApplicationContext());
    Log.d(TAG, "APICallsWorker: WORK CREATED");
}

@NonNull
@Override
public Result doWork() {
    nickname = getInputData().getString("nickname");
    zip = getInputData().getInt("zip", -1);
    performAPICalls();
    return Result.success();
}

private void performAPICalls() {
    WeatherApi weatherApi = RetrofitService.createService(WeatherApi.class);
    weatherApi.getWeatherWithZip(zip, Constants.API_KEY).enqueue(new Callback<WeatherResponse>() {
        @Override
        public void onResponse(Call<WeatherResponse> call, Response<WeatherResponse> response) {
            if(response.isSuccessful()){
                if(response.body() != null){
                    handleAPIResult(response.body());
                }
            } else{
                Toast.makeText(getApplicationContext(), "Please Enter a valid zip", Toast.LENGTH_SHORT).show();
            }
        }
        @Override
        public void onFailure(Call<WeatherResponse> call, Throwable t) {
            handleError(t);
        }
    });
}

private void handleAPIResult(WeatherResponse weatherResponse) {
    Log.d(TAG, "handleAPIResult: HERE");
    Completable.fromAction(() -> {
        String timestamp = StringManipulation.getCurrentTimestamp();
        int temperature = Integer.valueOf(Conversions.kelvinToFahrenheit(weatherResponse.getMain().getTemp()));
        String locationName = weatherResponse.getName();
        int windSpeed = Math.round(weatherResponse.getWind().getSpeed());
        int humidity = Math.round(weatherResponse.getMain().getHumidity());

        MyCity city = new MyCity(nickname, zip, timestamp, temperature, locationName, windSpeed, humidity);
        citiesDatabase.myCitiesDao().insert(city);
    }).observeOn(AndroidSchedulers.mainThread())
            .subscribeOn(Schedulers.io())
            .subscribe();
}

private void handleError(Throwable t) {
    Log.d(TAG, "handleError: ERROR: " + t.getMessage());
}

}

Прямо сейчас у меня есть кнопка в пользовательском интерфейсе, чтобы обновить все города одновременно (в конце концов, я хочу, чтобы это был простой прокрутка вниз для обновления или что-то в этом роде). Проблема заключается в том, что когда я нажимаю обновить все города, работа выполняется, но просмотр реселлера не обновляется (потому что новые данные ему не передаются), но если я изменяю конфигурацию (например, поворот экрана), новые данные будут отображаться.

Вот мой основной класс:

public class MainActivity extends AppCompatActivity implements AddCityDialog.AddCityDialogListener {

    private static final String TAG = "MainActivity";

    //Widgets
    private Button mAddNewCity;

    private RecyclerView mRecyclerView;
    private WeatherRecyclerAdapter mRecyclerAdapter;

    private ViewAddDeleteCitiesViewModel mViewDeleteViewModel;
    private ViewAddDeleteCitiesViewModelFactory mViewDeleteMyCitiesViewModelFactory;

    @Override
    protected void onCreate(Bundle savedInstanceState) {
        super.onCreate(savedInstanceState);
        setContentView(R.layout.activity_main);

        initWidgets();
        initViewModel();
        initRecyclerView();
        setupListeners();
    }


    public void initWidgets() {
        mAddNewCity = findViewById(R.id.btn_add_new_city);
    }

    public void initViewModel() {
        mViewDeleteMyCitiesViewModelFactory = new ViewAddDeleteCitiesViewModelFactory(this.getApplication());
        mViewDeleteViewModel = new ViewModelProvider(this, mViewDeleteMyCitiesViewModelFactory).get(ViewAddDeleteCitiesViewModel.class);

        mViewDeleteViewModel.observeAllCities().observe(this, cities -> mRecyclerAdapter.submitList(cities));
    }


    public void setupListeners() {
        mAddNewCity.setOnClickListener(v -> addCityDialog());

        mRecyclerAdapter.setOnItemClickListener(myCity -> Toast.makeText(MainActivity.this, "Item Clicked: ", Toast.LENGTH_SHORT).show());

        new ItemTouchHelper(new ItemTouchHelper.SimpleCallback(0, ItemTouchHelper.LEFT) {
            @Override
            public boolean onMove(@NonNull RecyclerView recyclerView, @NonNull RecyclerView.ViewHolder viewHolder, @NonNull RecyclerView.ViewHolder target) {
                return false;
            }

            @Override
            public void onSwiped(@NonNull RecyclerView.ViewHolder viewHolder, int direction) {
                mViewDeleteViewModel.delete(mRecyclerAdapter.getCityAt(viewHolder.getAdapterPosition()));
                Log.d(TAG, "onSwiped: Deleted");
            }
        }).attachToRecyclerView(mRecyclerView);
    }

    public void addCityDialog() {
        AddCityDialog addCityDialog = new AddCityDialog();
        addCityDialog.show(getSupportFragmentManager(), "Add City Dialog");
    }

    public void initRecyclerView() {
        mRecyclerView = findViewById(R.id.recycler_view);
        mRecyclerAdapter = new WeatherRecyclerAdapter();
        mRecyclerView.setAdapter(mRecyclerAdapter);
        mRecyclerView.setLayoutManager(new LinearLayoutManager(this));
        Log.d(TAG, "initRecyclerView: Recycler View Initialized");
    }

    /**
     * Uses information (@param nickname @param zip) from Dialog to add a new city to the room db
     * by passing the input to the one time worker class.
     * @param nickname
     * @param zip
     */
    @Override
    public void addCity(String nickname, String zip) {
        insertSingleCity(nickname, Integer.valueOf(zip));
        Log.d(TAG, "addCity: CITY ADDED MAIN ACTIVITY");

        updateAllCities(mViewDeleteViewModel.getAllCities());
    }

    public void insertSingleCity(String nickname, int zip) {
        OneTimeWorkRequest oneTimeWorkRequest = new OneTimeWorkRequest.Builder(InsertSingleCityWorker.class)
                .setInputData(DataManipulation.createInputData(nickname, zip))
                .build();

        WorkManager.getInstance(this).enqueue(oneTimeWorkRequest);
    }


    public void updateCities(View v){
        updateAllCities(mViewDeleteViewModel.getAllCities());
    }


    //Stars work to get API when a city is added
    private void updateAllCities(List<MyCity> cities) {
        Log.d(TAG, "startWork: here");
        for (MyCity city : cities) {
            OneTimeWorkRequest oneTimeWorkRequest = new OneTimeWorkRequest.Builder(UpdateAllCitiesWorker.class)
                    .setInputData(DataManipulation.createInputData(city.getId(), city.getNickname(), city.getZipCode()))
                    .build();

            WorkManager.getInstance(this).enqueue(oneTimeWorkRequest);
            Log.d(TAG, "startWork: WORK ENQUEUED");
        }
    }
}

Обновление всех рабочих городов:

    public UpdateAllCitiesWorker(@NonNull Context context, @NonNull WorkerParameters workerParams) {
    super(context, workerParams);
    citiesDatabase = MyCitiesDatabase.getInstance(getApplicationContext());
    Log.d(TAG, "APICallsWorker: WORK CREATED");
}

@NonNull
@Override
public Result doWork() {
    id = getInputData().getLong("id", -1);
    nickname = getInputData().getString("nickname");
    zip = getInputData().getInt("zip", -1);
    performAPICalls();
    return Result.success();
}

private void performAPICalls() {

    WeatherApi weatherApi = RetrofitService.createService(WeatherApi.class);


    weatherApi.getWeatherWithZip(zip, Constants.API_KEY).enqueue(new Callback<WeatherResponse>() {
        @Override
        public void onResponse(Call<WeatherResponse> call, Response<WeatherResponse> response) {
            if (response.isSuccessful()) {
                if (response.body() != null) {
                    handleAPIResult(response.body());
                }
            }
        }

        @Override
        public void onFailure(Call<WeatherResponse> call, Throwable t) {
            handleError(t);
        }
    });


}

private void handleAPIResult(WeatherResponse weatherResponse) {
    Log.d(TAG, "handleAPIResult: HERE");
    Completable.fromAction(() -> {
        String timestamp = StringManipulation.getCurrentTimestamp();
        int temperature = Integer.valueOf(Conversions.kelvinToFahrenheit(weatherResponse.getMain().getTemp()));
        String locationName = weatherResponse.getName();
        int windSpeed = Math.round(weatherResponse.getWind().getSpeed());
        int humidity = Math.round(weatherResponse.getMain().getHumidity());

        MyCity city = new MyCity(nickname, zip, timestamp, temperature, locationName, windSpeed, humidity);
        city.setId(id);
        citiesDatabase.myCitiesDao().update(city);
        Log.d(TAG, "run: city added");
    }).observeOn(AndroidSchedulers.mainThread())
            .subscribeOn(Schedulers.io())
            .subscribe();

}

private void handleError(Throwable t) {
    Log.d(TAG, "handleError: here");
}

}

И дао:

  @Dao
public interface MyCitiesDao {

    @Insert
    void insert(MyCity myCity);

    @Query("SELECT * FROM cities ORDER BY id ASC")
    LiveData<List<MyCity>> observeAllCities();

    @Query("SELECT * FROM cities ORDER BY id ASC")
    List<MyCity> getAllCities();

    @Delete
    void delete(MyCity... city);

    @Update
    void update(MyCity... city);
}

Вот как выглядит приложение

Answer 1

Я думаю, что настоящая проблема в том, что вы звоните submitList, потому что согласно документам

Когда вы вызываете submitList, он отправляет новый список для отображения и отображения.

Вот почему всякий раз, когда вы вызываете submitList для предыдущего (уже отправленного списка), он не вычисляет Diff и не уведомляет адаптер об изменении в наборе данных.

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

submitList(null);
submitList(cities);

Другим решением будет переопределение submitList в классе вашего адаптера

@Override
public void submitList(final List<MyCity> list) {
    super.submitList(list != null ? new ArrayList<>(list) : null);
}

Третьим решением будет создайте копию списка, как показано ниже

submitList(new ArrayList(cities))

Пожалуйста, посмотрите на этот вопрос stackoverflow для получения дополнительной информации source