java flowable_rxJava reactivex.Flowable使用

/**

* 加载本地资源并显示控件上，可用于任何比较耗时的请求

*/

private void setImageResource(int resourceId) {

Flowable.just(resourceId)

.subscribeOn(Schedulers.io())

// 参数类型 返回值

.map(new Function() {

@Override

public Bitmap apply(@NonNull Integer integer) throws Exception {

// return BitmapUtils.createCircleImage(BitmapFactory.decodeResource(MainActivity.this.getResources(), integer));;

return null;

}

})

// 事件订阅 结果返回

.subscribe(new Consumer() {

@Override

public void accept(@NonNull Bitmap bitmap) throws Exception {

}

});

}

/**

* 没有请求参数的耗时操作

*/

public void create() {

Flowable.create(new FlowableOnSubscribe() {

@Override

public void subscribe(FlowableEmitter e) throws Exception {

//要执行的事件

e.onNext(GriddingDatabase.getInstance().problemTypeDao().getSize());

e.onComplete();

}

}, BackpressureStrategy.ERROR)

.subscribeOn(Schedulers.io())

.observeOn(Schedulers.io())

.subscribe(new Consumer() {

@Override

public void accept(@NonNull Integer integer) throws Exception {

}

});

}

/**

* 遍历list 提取某一条件的bean

*/

private void list(List staffInfoList) {

Flowable.fromIterable(staffInfoList)

.filter(new Predicate() {

@Override

public boolean test(@NonNull StaffInfo staffInfo) throws Exception {

return staffInfo.isChecked();

}

}).subscribe(new Consumer() {

@Override

public void accept(@NonNull StaffInfo staffInfo) throws Exception {

}

});

}

/**

*遍历list

*/

private void forList(List staffInfoList) {

Flowable.just(staffInfoList)

.flatMap(new Function, Publisher>() {

@Override

public Publisher apply(@NonNull List staffInfoList) throws Exception {

return Flowable.fromIterable(staffInfoList);

}

})

.subscribe(new Consumer() {

@Override

public void accept(@NonNull StaffInfo staffInfo) throws Exception {

}

});

}