原文地址：https://android.jlelse.eu/a-nice-combination-of-rxjava-and-diffutil-fe3807186012
如果你使用RecyclerView，并且保持了与API相同的更新，你也许会注意到DIffUtil类添加了好几个版本，这个优秀的工具类通过将已经存在的数据和新生成的数据进行对比，然后调用notifyItemInserted和notifyItemRemoved来轻松实现数据的改变。你需要做的就是实现一个回调，在回调中将现有数据和新获取的数据进行比较。
private static class MyDiffCallback extends DiffUtil.Callback{
private List<Thing> current;
private List<Thing> next;
public MyDiffCallback(List<Thing> current,List<Thing> next){
this.current = current;
this.next = next;
}
@Override
public int getOldListSize(){
return current.size();
}
@Override
public int getNewListSize(){
return next.size();
}
@Override
public boolean areItemsTheSame(int oldItemPosition,int newItemPosition){
Thing currentItem = current.get(oldItemPosition);
Thing nextItem = next.get(newItemPosition);
return currentItem.getId() == nextItem.getId();
}
@Override
public boolean areContentsTheSame(int oldItemPosition,int newItemPosition){
Thing currentItem = current.get(oldItemPosition);
Thing nextItem = current.get(newItemPosition);
return currentItem.equals(nextItem);
}
}
DiffResult diffResult = DiffUtil.calculateDiff(new MyDiffCallback(current,next),true);
diffResult.dispatchUpdatesTo(adapter);
上述代码显示了如何实现回调，如何执行计算以及如何将notify-call分配到RecyclerView的适配器。
然而这里还存在一个挑战那就是如果数据量特别大的话，或者对比比较复杂的情况下，你不能在主线程中调用计算功能，需要把这些移到一个后台进程，然后把结果发送给主线程用来设置新的数据，
现在事情变得很棘手，因为DiggUtil计算需要用到已经存在的数据和新的数据，如果你的适配器有一个setData()方法，那么他将需要一个getData()方法，这意味着将从多个线程访问数据，因此你需要一些用于同步或者线程安全的数据结构，如何避免这种情况呢。
使用Rxjava将会解决一切问题，假设你有一个Flowable<List<Thing>> listOfThings,他将发出RecycleView将显示的获取的新版本的数据，我们可以在IO或者在计算线程调度以免阻塞主线程，然后再主线程进行观察事件将数据传递给adapter。
ThingRepository
.latestThings(2,TimeUnit.SECONDS)
.subscribeOn(computation())
.observeOn(mainThread())
.subscribe(things -> {
adapter.setThings(things);
adapter.notifyDataSetChanged();
})
以上的代码确保了在计算线程中获取新的数据列表，并且发送给主线程然后调用adapter的notifyDataSetChanged，这样做有效，但是看起来不是很好，因为每个新列表都需要重新绘制。
为了使用DiffUtil，我们需要调用calculateDiff()方法，并将DiffResult与最新的List<Thing>一起传递给我们的订阅者，一个简单的方法是使用Pair类，这是支持库中一个简单并且强大的实现类，我们将更改订阅以接受Pair<List<Thing>,<DiffResult>>事件。
.subscribe(listDiffResultPair -> {
List<Thing> nextThings = listDiffResultPair.first;
DiffUtil.DiffResult diffResult = listDiffResultPair.second;
adapter.setThings(nextThings);
diffResult.dispatchUpdatesTo(adapter);
});
.scan()
传递给DiffUtil.calculateDiff()的回调需要当前列表和新列表才能生效，我们如何确保我们从数据源所获取的每一个新列表，我们也想获取上一个事件，这也是RxJava更神秘的一个运算符scan(),scan的初始值将是一个由空列表和空值作为DiffResult值组成的对。
现在我们将会调用calculateDiff()并将其列在我们的Pair中，我们使用结果构建一个新的DiffResult。
我们还有一件事要考虑，如果我们这样离开，第一件事将包含一个DiffResult为null的Pair，所以我们必须在我们的订阅中对null进行检查，但是，由于也有可能我们开始的时候是一个空列表，所以我们可以使用skip运算符来简单的跳过他，这将会忽略第一个事件。
List<Thing> emptyList = new ArrayList<>();
adapter.setThings(emptyList);
Pair<List<Things>,DiffUtil.DiffResult> initialPair = Pair.create(emptyList,null);
ThingRepository
.latestThings(2,TimeUnit.SECONDS)
.scan(initialPair,(pair,next) -> {
MyDiffCallback callback = new MyDiffCallback(pair.first,next);
DiffUtil.DiffResult result = DiffUtil.calculateDiff(callback);
return Pair.create(next,result);
})
.skip(1);
这可以使用RxJava和一些职能操作符在后台线程上使用DiffUtil，还没有必要考虑适配器保存的当前数据的任何同步或并发，我们的实力应用程序的结果可以在下面看到。
Demo地址：
