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 {
}
});
}
java flowable_rxJava reactivex.Flowable使用相关推荐
- RxJava2出现:Unable to create call adapter for io.reactivex.Flowable
前面一直使用的是Rxjava 1.x 版本,最近 Rxjava 2.x 版本发布了,并且支持了背压,便换成了 Rxjava 2.x 版本.更换之后出现了下面的错误. Caused by: java.l ...
- Java中ReactiveX(RxJava)的使用
1.1 ReactiveX概述 ReactiveX官网:ReactiveX 1.1.1 Android的MVP开发模式 MVP的工作流程 Presenter负责逻辑的处理 Model提供数据 View ...
- NoClassDefFoundError io.reactivex.Flowable
各路宝宝都看看这个异常: java.lang.NoClassDefFoundError: io.reactivex.Flowableat io.reactivex.Observable.bufferS ...
- java 图片 滤镜_Java实现图片滤镜的高级玩法
cv4j是一个图像处理库 具体介绍,可以参考上一篇文章java实现图片的滤镜效果 目前,cv4j 已经支持了十几种滤镜的效果,并优化了之前的算法,除此之外我们还使用了 Rxjava2 来封装滤镜的操作 ...
- flowable画图教程_给初学者的RxJava2.0教程(七): Flowable
作者博客http://www.jianshu.com/u/c50b715ccaeb前言上一节里我们学习了只使用Observable如何去解决上下游流速不均衡的问题,之所以学习这个是因为Observab ...
- java web3j4.8.4版本的使用记录
最近公司做NFT市场开发,特记录一下自己在使用web3j组件测试调用区块链合约的时使用的方法和踩过的坑,便于自己以后查看. 主要用到工具有4个 idea,谷歌浏览,小狐狸钱包(metamask)插件, ...
- Flowable学习笔记(二、BPMN 2.0-基础 )
转载自 Flowable学习笔记(二.BPMN 2.0-基础 ) 1.BPMN简介 业务流程模型和标记法(BPMN, Business Process Model and Notation)是一套图 ...
- Flowable工作流引擎
Flowable工作流引擎 Flowable-基础篇(根据BV1Pb4y1p7Ku整理) 一.简介 Flowable是BPMN的一个基于java的软件实现,不过Flowable不仅仅包括BPMN,还有 ...
- 小白学流程引擎-FLowable(五) — BPMN2.0模型规范
前言: 不用到处百度BPMN2的博客了,本篇文章带你系统掌握BPMN2规范的核心知识点.全文2万字,全覆盖BPMN2知识点,图文并茂,泡杯咖啡,慢慢细品- 一.BPMN是什么 BPMN(Busines ...
最新文章
- LeetCode实战:环形链表 II
- NLP情感分析 动手学深度学习博客
- linux运维人员必会运维工具
- python3中unicode怎么写_详解python3中ascii与Unicode使用
- 路由及iptables学习笔记
- POJ 2251 Dungeon Master
- MyBatis的插入数据操作
- 【352天】我爱刷题系列111(2018.01.23)
- 随机过程及其稳态stability
- NLP预训练之路——从word2vec, ELMo到BERT
- 手机方舟官方服务器稳定吗,方舟生存进化手游选官服还是S服好?有什么区别...
- Web Components 系列(八)—— 自定义组件的样式设置
- 程序员需要掌握哪些软技能?
- 记一个函数定义中,形参是空列表时要注意的问题
- wordpress怎么修改地址栏小图标
- Struts2 面试题
- SU2021下载SketchUp2021最新下载安装教程SU草图大师2021下载安装
- 继“世界性别平等大会”圆满召开后,喀拉拉邦首席部长为“性别平等园区”揭幕
- IBM服务器硬盘灯不正常闪烁的解决办法(新硬盘绿灯闪烁)
- mysql如何返回上一步_月亮上没有火箭和发射塔,嫦娥五号完成任务后,是如何起飞返回的...