欢马劈雪的技术文章、集册、实例源码

时代Java，与您同行！关注微信公众号，关注前沿技术，微信搜索：nowjava或时代Java，也可点击这里扫码关注

时代Java

登录注册

京东自营 + 国补 iPhone 历史最低价国家补贴享8折

欢马劈雪

RxJava文档和教程

RxJava入门指南RxJava使用示例实现自定义操作符自定义插件Backpressure TODO错误处理Android模块参与开发补充阅读材料Phantom-Operators

欢马劈雪 2020-08-04 17:37:59 2020-08-04 05:37:59

rxjava，文档，教程， reactivex，中文翻译
按字母顺序排列的全部操作符列表

aggregate( ) — see reduce( )all( ) — determine whether all items emitted by an Observable meet some criteriaamb( ) — given two or more source Observables, emits all of the items from the first of these Observables to emit an itemambWith( ) — instance version of amb( )and( ) — combine the emissions from two or more source Observabl…

欢马劈雪 2020-08-04 17:37:59 2020-08-04 05:37:59

字母，顺序排列，全部，操作符，列表
字符串操作

StringObservable 类包含一些用于处理字符串序列和流的特殊操作符，如下： — 将一个字符串的Observable转换为一个行序列的Observable，这个Observable将原来的序列当做流处理，然后按换行符分割 — 将一个多字节的字符流转换为一个Observable，它按字符边界发射字节数组 — 对一个发射字符串的Observable执行变换操作，变换后的Observable发射一个在原始字符串中表示多…

欢马劈雪 2020-08-04 17:37:59 2020-08-04 05:37:59

字符串，操作， reactivex，文档，中文翻译
BlockingObservable的方法

BlockingObservable的方法不是将一个Observable变换为另一个，也不是过滤Observables，它们会打断Observable的调用链，会阻塞等待直到Observable发射了想要的数据，然后返回这个数据（而不是一个Observable）。要将一个Observable转换为一个BlockingObservable，你可以使用Observable.toBlocking或BlockingObservable.from方法。Javadoc: [Observable.

欢马劈雪 2020-08-04 17:37:59 2020-08-04 05:37:59

blockingobservable，方法， reactivex，文档，中文翻译
To

将Observable转换为另一个对象或数据结构ReactiveX的很多语言特定实现都有一种操作符让你可以将Observable或者Observable发射的数据序列转换为另一个对象或数据结构。它们中的一些会阻塞直到Observable终止，然后生成一个等价的对象或数据结构；另一些返回一个发射那个对象或数据结构的Observable。在某些ReactiveX实现中，还有一个操作符用于将Observable转换成阻塞式的。

欢马劈雪 2020-08-04 17:37:59 2020-08-04 05:37:59

reactivex，文档，中文翻译
Replay

保证所有的观察者收到相同的数据序列，即使它们在Observable开始发射数据之后才订阅可连接的Observable (connectable Observable)与普通的Observable差不多，不过它并不会在被订阅时开始发射数据，而是直到使用了Connect操作符时才会开始。用这种方法，你可以在任何时候让一个Observable开始发射数据。

欢马劈雪 2020-08-04 17:37:59 2020-08-04 05:37:59

replay， reactivex，文档，中文翻译
RefCount

让一个可连接的Observable行为像普通的Observable可连接的Observable (connectable Observable)与普通的Observable差不多，不过它并不会在被订阅时开始发射数据，而是直到使用了Connect操作符时才会开始。用这种方法，你可以在任何时候让一个Observable开始发射数据。RefCount操作符把从一个可连接的Observable连接和断开的过程自动化了。

欢马劈雪 2020-08-04 17:37:59 2020-08-04 05:37:59

refcount， reactivex，文档，中文翻译
Publish

将普通的Observable转换为可连接的Observable可连接的Observable (connectable Observable)与普通的Observable差不多，不过它并不会在被订阅时开始发射数据，而是直到使用了Connect操作符时才会开始。用这种方法，你可以在任何时候让一个Observable开始发射数据。RxJava的实现为publish。Javadoc: [publish()](http://reactivex.io/RxJava/javadoc/rx/Observable.

欢马劈雪 2020-08-04 17:37:59 2020-08-04 05:37:59

publish， reactivex，文档，中文翻译
Connect

让一个可连接的Observable开始发射数据给订阅者可连接的Observable (connectable Observable)与普通的Observable差不多，不过它并不会在被订阅时开始发射数据，而是直到使用了Connect操作符时才会开始。用这个方法，你可以等待所有的观察者都订阅了Observable之后再开始发射数据。

欢马劈雪 2020-08-04 17:37:59 2020-08-04 05:37:59

connect， reactivex，文档，中文翻译
连接操作

这一节解释ConnectableObservable 和它的子类以及它们的操作符： — 指示一个可连接的Observable开始发射数据 — 将一个Observable转换为一个可连接的Observable — 确保所有的订阅者看到相同的数据序列，即使它们在Observable开始发射数据之后才订阅 — 让一个可连接的Observable表现得像一个普通的Observable一个可连接的Observable与普通的Observable差不多，除了…

欢马劈雪 2020-08-04 17:37:59 2020-08-04 05:37:59

连接，操作， reactivex，文档，中文翻译
异步操作

下面的这些操作符属于单独的rxjava-async模块，它们用于将同步对象转换为Observable。

欢马劈雪 2020-08-04 17:37:59 2020-08-04 05:37:59

异步操作， reactivex，文档，中文翻译
算术和聚合操作

Average计算原始Observable发射数字的平均值并发射它Average操作符操作符一个发射数字的Observable，并发射单个值：原始Observable发射的数字序列的平均值。这个操作符不包含在RxJava核心模块中，它属于不同的rxjava-math模块。它被实现为四个操作符：averageDouble, averageFloat, averageInteger, averageLong。

欢马劈雪 2020-08-04 17:37:59 2020-08-04 05:37:59

算术，聚合，操作， reactivex，文档
算术和聚合操作

Average计算原始Observable发射数字的平均值并发射它Average操作符操作符一个发射数字的Observable，并发射单个值：原始Observable发射的数字序列的平均值。这个操作符不包含在RxJava核心模块中，它属于不同的rxjava-math模块。它被实现为四个操作符：averageDouble, averageFloat, averageInteger, averageLong。

欢马劈雪 2020-08-04 17:37:59 2020-08-04 05:37:59

算术，聚合，操作， reactivex，文档
算术和聚合操作

本页展示的操作符用于对整个序列执行算法操作或其它操作，由于这些操作必须等待数据发射完成（通常也必须缓存这些数据），它们对于非常长或者无限的序列来说是危险的，不推荐使用。

欢马劈雪 2020-08-04 17:37:59 2020-08-04 05:37:59

算术，聚合，操作， reactivex，文档
条件和布尔操作

All判定是否Observable发射的所有数据都满足某个条件传递一个谓词函数给All操作符，这个函数接受原始Observable发射的数据，根据计算返回一个布尔值。All返回一个只发射一个单个布尔值的Observable，如果原始Observable正常终止并且每一项数据都满足条件，就返回true；如果原始Observable的任何一项数据不满足条件就返回False。

欢马劈雪 2020-08-04 17:37:59 2020-08-04 05:37:59

条件，布尔，操作， reactivex，文档
条件和布尔操作

All判定是否Observable发射的所有数据都满足某个条件传递一个谓词函数给All操作符，这个函数接受原始Observable发射的数据，根据计算返回一个布尔值。All返回一个只发射一个单个布尔值的Observable，如果原始Observable正常终止并且每一项数据都满足条件，就返回true；如果原始Observable的任何一项数据不满足条件就返回False。

欢马劈雪 2020-08-04 17:37:59 2020-08-04 05:37:59

条件，布尔，操作， reactivex，文档
条件和布尔操作

All判定是否Observable发射的所有数据都满足某个条件传递一个谓词函数给All操作符，这个函数接受原始Observable发射的数据，根据计算返回一个布尔值。All返回一个只发射一个单个布尔值的Observable，如果原始Observable正常终止并且每一项数据都满足条件，就返回true；如果原始Observable的任何一项数据不满足条件就返回False。

欢马劈雪 2020-08-04 17:37:59 2020-08-04 05:37:59

条件，布尔，操作， reactivex，文档
条件和布尔操作

All判定是否Observable发射的所有数据都满足某个条件传递一个谓词函数给All操作符，这个函数接受原始Observable发射的数据，根据计算返回一个布尔值。All返回一个只发射一个单个布尔值的Observable，如果原始Observable正常终止并且每一项数据都满足条件，就返回true；如果原始Observable的任何一项数据不满足条件就返回False。

欢马劈雪 2020-08-04 17:37:59 2020-08-04 05:37:59

条件，布尔，操作， reactivex，文档
条件和布尔操作

All判定是否Observable发射的所有数据都满足某个条件传递一个谓词函数给All操作符，这个函数接受原始Observable发射的数据，根据计算返回一个布尔值。All返回一个只发射一个单个布尔值的Observable，如果原始Observable正常终止并且每一项数据都满足条件，就返回true；如果原始Observable的任何一项数据不满足条件就返回False。

欢马劈雪 2020-08-04 17:37:59 2020-08-04 05:37:59

条件，布尔，操作， reactivex，文档
条件和布尔操作

这个页面的操作符可用于根据条件发射或变换Observables，或者对它们做布尔运算：条件操作符 — 给定多个Observable，只让第一个发射数据的Observable发射全部数据 — 发射来自原始Observable的数据，如果原始Observable没有发射数据，就发射一个默认数据(rxjava-computation-expressions) — 发射原始Observable的数据序列，然后重复发射这个序列直到不满足这个条件为…

欢马劈雪 2020-08-04 17:37:59 2020-08-04 05:37:59

条件，布尔，操作， reactivex，文档

个人简介

欢马劈雪
纵马驰骋迎雪而行
获得 161620 积分
https://nowjava.com/creator/10001

欢马劈雪

RxJava文档和教程

按字母顺序排列的全部操作符列表

字符串操作

BlockingObservable的方法

To

Replay

RefCount

Publish

Connect

连接操作

异步操作

算术和聚合操作

算术和聚合操作

算术和聚合操作

条件和布尔操作

条件和布尔操作

条件和布尔操作

条件和布尔操作

条件和布尔操作

条件和布尔操作

个人简介

欢马劈雪

纵马驰骋迎雪而行

获得 161620 积分

https://nowjava.com/creator/10001

热门标签

社区

关于