使用RxJava对Cursor的操作Sample
RxCursorSample是我在一个用Rx特性实现的图片多选/单选选择器
特性：
1.使用RxJava操作ContentProvider的Cursor，并且在图片详情页面，使用RxJava操作符实现了一个RecyclerView的简单动画，提升了用户体验
2.使用RxBus实现组件通信
3.适配了Android 6.0的权限请求
其他几个特性不分析了，主要分析下项目中的Rx：（源码在文章结尾）
** RxBus（这里是我的一篇关于RxBus的简书）负责了Fragment和Activity通信**
Activity接收RxBus的事件，然后通过FragmentManager切换Fragment。
下面是在ImagePickerActivity的主要代码：
private void initRxBus() {
// 接收 切换相册事件
rxSubscriptions.add(RxBus.getDefault().toObserverable(AddDetailEvent.class)
.map(addDetailEvent -> addDetailEvent.getBucketName())
.subscribe(bucketName -> {
// add DetailExploreFragment
addFragment(DetailExploreFragment.newInstance(bucketName, isMultiplePick));
}, throwable -> {
throwable.printStackTrace();
Toast.makeText(this, R.string.yo_switch_bucket_exception,Toast.LENGTH_SHORT).show();
}));
// 接收 切换预览事件
rxSubscriptions.add(RxBus.getDefault().toObserverable(AddPreviewEvent.class)
.map(addPreviewEvent -> addPreviewEvent.getImgs())
.subscribe(imgs -> {
toolbar.setTitle(R.string.yo_preview);
// add PreviewFragment
addFragment(PreviewFragment.newInstance(imgs, isMultiplePick));
}, throwable -> {
throwable.printStackTrace();
Toast.makeText(this, R.string.yo_switch_preview_exception, Toast.LENGTH_SHORT).show();
}));
}
上面的代码中，比如点击了“预览”，由DetailExploreFragment跳转至PreviewFragment，通过RxBus将事件传递到Activity，Activity再切换PreviewFragment
下面是DetailExploreFragment 中的代码，点击“预览”，发送事件
btnPreview.setOnClickListener((v) -> {
// addFragment
RxBus.getDefault().post(new AddPreviewEvent(imgs));
});
** RxJava操作ContentProvider的Cursor**
创建Observable<Cursor>的代码：
private Observable<Cursor> cursorObservable() {
return Observable.create(new Observable.OnSubscribe<Cursor>() {
@Override
public void call(Subscriber<? super Cursor> subscriber) {
if (!subscriber.isUnsubscribed()) {
try{
Cursor cursor = getCursor();
// 判断!subscriber.isUnsubscribed() 是为了在取消订阅时，保证cursor可以及时关闭
while (cursor.moveToNext() && !subscriber.isUnsubscribed()) {
subscriber.onNext(cursor);
}
subscriber.onCompleted();
}catch(Exeception e){
subscriber.onError(e);
}finally {
assert cursor != null;
cursor.close();
}
}
}
});
}
private Cursor getCursor() {
String[] mediaColumns = new String[]{
MediaStore.Images.Media.BUCKET_DISPLAY_NAME,
MediaStore.Images.Media.DATA,
"COUNT(*) AS " + COLUMN_NAME_COUNT
};
// SELECT _data, COUNT(*) AS v_count FROM video WHERE ( GROUP BY bucket_display_name)
String selection = " 1=1 ) GROUP BY (" + MediaStore.Images.Media.BUCKET_DISPLAY_NAME;
return _activity.getContentResolver().query(MediaStore.Images.Media.EXTERNAL_CONTENT_URI, mediaColumns, selection, null, null);
}
Cursor是个比较特殊的数据库操作类，在该例中，在Cursor的游标移动到结尾之前，会一直发射Observable<Cursor>的数据源。
代码中while里有判断!subscriber.isUnsubscribed()，是为了在取消订阅时而cursor还没有执行完的情况下，保证cursor可以及时关闭。
下面在IO线程中将Observable<Cursor>转换成List<BucketEntity>，最终在主线程中的RecyclerView中绑定数据显示。
private void initData() {
subscription = cursorObservable()
.subscribeOn(Schedulers.io())
.filter(cursor -> {
String path = cursor.getString(cursor.getColumnIndex(MediaStore.Images.Media.DATA));
return !path.endsWith(".gif");
})
.map(cursor -> {
String path = cursor.getString(cursor.getColumnIndex(MediaStore.Images.Media.DATA));
String bucket_name = cursor.getString(cursor.getColumnIndex(MediaStore.Images.Media.BUCKET_DISPLAY_NAME));
int count = cursor.getInt(cursor.getColumnIndex(COLUMN_NAME_COUNT));
return new BucketEntity(bucket_name, count, path);
})
.toList()
// 如果不用toList()转成List 一定要调用onBackpressureBuffer()方法,防止数据源发射过快,导致异常MissingBackpressureException
// .onBackpressureBuffer()
.observeOn(AndroidSchedulers.mainThread())
.subscribe(
bucketEntity -> {
adapter.setDatas(bucketEntity);
}, throwable -> {
throwable.printStackTrace();
Toast.makeText(_activity, R.string.yo_find_exception, Toast.LENGTH_SHORT).show();
}
);
}
filter操作符过滤掉的gif图片，map操作符将Observable<Cursor>对象转换成Obser<BucketEntity>，这里有2种绑定数据到RecyclerView的方法：
1. 数据源集合绑定：
使用toList操作符，它将一连串的Observable<T>类型数据源集合转换成一个Observable<List<T>>返回，最后一次性绑定数据到RecyclerView上
2. 单数据源依次绑定：
即通过Adapter.addData(bean)，一个一个数据逐个绑定到RecyclerView上，但是如果直接这样操作，则会报预测MissingBackpressureException的异常，该异常是由于数据源发射速度过快导致的。
可以使用onBackpressureBuffer操作符解决,它可以缓冲发射速度过快的数据源，直到所有数据源全部发射出去。
这个例子中，使用的是第一种方法
下面这段代码使用了第二种，同时加入了一个操作符，视觉上形成一个逐条加入的动画
private void initData() {
subscription = cursorObservable()
.subscribeOn(Schedulers.io())
// 延迟60ms发射数据 形成动画, delay默认在computation线程 要主动切换到当前的线程
.delay(60, TimeUnit.MILLISECONDS, Schedulers.immediate())
.filter(cursor -> {
String path = cursor.getString(cursor.getColumnIndex(MediaStore.Images.Media.DATA));
return !path.endsWith(".gif");
})
.map(cursor -> {
String path = cursor.getString(cursor.getColumnIndex(MediaStore.Images.Media.DATA));
return new File(path);
})
// onBackpressureBuffer()方法,防止数据源发射过快引起的MissingBackpressureException
.onBackpressureBuffer()
.observeOn(AndroidSchedulers.mainThread())
.subscribe(
file -> {
adapter.addData(file);
}, throwable -> {
throwable.printStackTrace();
Toast.makeText(_activity, R.string.yo_find_exception, Toast.LENGTH_SHORT).show();
}
);
}
delay操作符可以延迟发射数据源。
因为该操作符默认在computation线程中运行，我们需要延迟的时间在数据源处理的IO线程上，所以主动指定在Schedules.immediate()上，即当前的IO线程上。（关于RxJava的线程高效使用，可以参考小鄧子的这篇译文）
这样的话，每隔60ms观察者就会收到一个经过加工的File数据源，然后将其绑定到RecyclerView上。
在视觉上，每个RecyclerView的Item都会在上个Item显示后的60ms后显示，仅仅通过一个操作符完成了一个Item显示动画 :)
更多详情可以查看源码，这里是完整的代码。
