답변

1

나는이 기능을 구현하기위한 다음 클래스를 사용

package com.mlsdev.enjoymusic.data.repository; 

import android.arch.paging.DataSource; 
import android.arch.paging.TiledDataSource; 
import android.arch.persistence.room.InvalidationTracker; 
import android.support.annotation.NonNull; 
import android.support.annotation.WorkerThread; 
import android.util.Log; 

import com.mlsdev.enjoymusic.data.local.DeezerDatabase; 
import com.mlsdev.enjoymusic.data.local.Table; 

import java.io.IOException; 
import java.util.List; 
import java.util.Set; 

import retrofit2.Call; 
import retrofit2.Response; 

/** 
* Created by stafievsky on 09.10.17. 
*/ 

public abstract class PagedNetworkBoundResource<ResultType, RequestType> extends TiledDataSource<ResultType> { 

    private final InvalidationTracker.Observer mObserver; 
    private DeezerDatabase db; 

    public PagedNetworkBoundResource(DeezerDatabase db) { 
     this.db = db; 
     mObserver = new InvalidationTracker.Observer(Table.States.PLAY_STATE) { 

      public void onInvalidated(@NonNull Set<String> tables) { 
       invalidate(); 
      } 
     }; 
     this.db.getInvalidationTracker().addWeakObserver(mObserver); 
    } 


    @Override 
    public boolean isInvalid() { 
     db.getInvalidationTracker().refreshVersionsSync(); 
     return super.isInvalid(); 
    } 

    @Override 
    public int countItems() { 
     return DataSource.COUNT_UNDEFINED; 
    } 

    @Override 
    public List<ResultType> loadRange(int startPosition, int count) { 
     if (startPosition == 0 && count == 20) { 
      clearDB(); 
     } 
     fetchFromNetwork(startPosition, count); 
     return loadFromDb(startPosition, count); 
    } 

    public abstract void clearDB(); 

    @WorkerThread 
    private void fetchFromNetwork(int startPosition, int count) { 
     if (createCall(startPosition, count) != null) 
      try { 
       Response<RequestType> response = createCall(startPosition, count).execute(); 
       if (response.isSuccessful() && response.code() == 200) { 
        saveCallResult(response.body()); 
       } 
      } catch (IOException e) { 
       e.printStackTrace(); 
      } 
    } 

    @WorkerThread 
    protected abstract void saveCallResult(@NonNull RequestType item); 


    @WorkerThread 
    protected abstract List<ResultType> loadFromDb(int startPosition, int count); 

    @WorkerThread 
    protected abstract Call<RequestType> createCall(int startPosition, int count); 
} 

그리고이 클래스의 구현 :

public LiveData<PagedList<ChartAlbumDao.Album>> getAlbums() { 

    return new LivePagedListProvider<Integer, ChartAlbumDao.Album>() { 
     @Override 
     protected DataSource<Integer, ChartAlbumDao.Album> createDataSource() { 
      return new PagedNetworkBoundResource<ChartAlbumDao.Album, ModelList<ChartAlbumEntity>>(db) { 

       @Override 
       public void clearDB() { 

       } 

       @Override 
       protected void saveCallResult(@NonNull ModelList<ChartAlbumEntity> item) { 
        if (item != null) { 
         chartAlbumDao.saveAlbums(item.getItems()); 
        } 
       } 

       @NonNull 
       @Override 
       protected List<ChartAlbumDao.Album> loadFromDb(int startPosition, int count) { 
        return chartAlbumDao.loadAlbums(count, startPosition); 
       } 

       @NonNull 
       @Override 
       protected Call<ModelList<ChartAlbumEntity>> createCall(int startPosition, int count) { 
        return deezerService.getChartAlbums(startPosition, count); 
       } 
      }; 
     } 

    }.create(0, new PagedList.Config.Builder() 
      .setEnablePlaceholders(false) 
      .setPageSize(20) 
      .setInitialLoadSizeHint(20) 
      .build()); 
} 
+0

좋아 보인다. 고맙습니다! –

+0

데이터가 무효화되면 loadRange가 다시 호출됩니까? 그렇다면 데이터를 다시 가져 오지 않도록 어떻게 제어합니까? 그렇지 않은 경우 TiledDataSource는 업데이트 할 항목을 어떻게 알 수 있습니까? –

+0

그리고 loadFromDb 메서드에서 데이터베이스가 처음 항목이기 때문에 항목이 아직 없는데 네트워크에서 가져 오는 경우에는 어떻게됩니까? loadRange 메소드가 count보다 적은 수의 항목을 수신하면 paged list가 그것이 목록의 끝임을 이해합니다. –