mcxiaoke/rxdocs

Rx和RxJava文档中文翻译项目

ReactiveX/RxJava文档中文版

项目地址：https://github.com/mcxiaoke/RxDocs，欢迎Star和帮忙改进。

有任何意见或建议，到这里提出 Create New Issue

阅读地址

• ReactiveX文档中文翻译
• PDF/ePub/Mobi格式下载

说明

• 大部分是翻译自 ReactiveX.io 和 RxJava Wiki，修正了原文的一些错误，补充了详细的说明和示例

版本历史

• 1.0.1 - 2017.07.20 图片链接修正，文本修正
• 1.0.0 - 2016.11.28 文本修正和润色，感谢@jiefly/@donglua/@cccxm等帮忙完善
• 0.9.5 - 2016.03.14 文本修正和润色，感谢@htoooth/@AlanCheen/@Ydcool/@loshine/@ppoffice帮忙完善
• 0.9.0 - 2015.11.25 修正错误和文本润色，感谢@slb1988/@htoooth/@jiyee/@donglua帮忙完善
• 0.8.0 - 2015.07.27 完成全部文档的初步审校，修正了部分用词不当的地方
• 0.7.0 - 2015.07.24 完成全部文档的初译，调整了目录的部分链接和文本
• 0.6.0 - 2015.07.22 完成绝大部分文档的翻译，使用GitBook发布初始版本

目录

• ReactiveX - 什么是Rx，Rx的理念和优势
• Observables - 简要介绍Observable的观察者模型
• Single - 一种特殊的只发射单个值的Observable
• Subject - Observable和Observer的复合体，也是二者的桥梁
• Scheduler - 介绍了各种异步任务调度和默认调度器
• All Operators List - 按字母顺序的全部操作符列表
• Operators Categories - 按目录分类的主要操作符列表
  • Creating 创建操作 - Create/Defer/From/Just/Start/Repeat/Range
  • Transforming 变换操作 - Buffer/Window/Map/FlatMap/GroupBy/Scan
  • Filtering 过滤操作 - Debounce/Distinct/Filter/Sample/Skip/Take
  • Combining 结合操作 - And/StartWith/Join/Merge/Switch/Zip
  • Error Handling 错误处理 - Catch/Retry
  • Utility 辅助操作 - Delay/Do/ObserveOn/SubscribeOn/Subscribe
  • Conditional 条件和布尔操作 - All/Amb/Contains/SkipUntil/TakeUntil
  • Mathematical 算术和聚合操作 - Average/Concat/Count/Max/Min/Sum/Reduce
  • Async 异步操作 - Start/ToAsync/StartFuture/FromAction/FromCallable/RunAsync
  • Connect 连接操作 - Connect/Publish/RefCount/Replay
  • Convert 转换操作 - ToFuture/ToList/ToIterable/ToMap/toMultiMap
  • Blocking 阻塞操作 - ForEach/First/Last/MostRecent/Next/Single/Latest
  • String 字符串操作 - ByLine/Decode/Encode/From/Join/Split/StringConcat
• RxJava文档和教程
  • RxJava入门指南
  • RxJava使用示例
  • 实现自定义操作符
  • 自定义插件
  • Backpressure
  • 错误处理
  • Android模块
  • 参与开发
  • 补充阅读材料

链接

• ReactiveX.io
• RxJava Wiki
• RxJava Javadoc
• RxMarbles
• Advanced RxJava
• Intro to Rx
• MSDN

---

许可协议

• 署名-非商业性使用-相同方式共享 4.0 国际

---

联系方式

• Blog: http://blog.mcxiaoke.com
• Github: https://github.com/mcxiaoke
• Email: [email protected]

开源项目

• Rx文档中文翻译: https://github.com/mcxiaoke/RxDocs
• MQTT协议中文版: https://github.com/mcxiaoke/mqtt
• Awesome-Kotlin: https://github.com/mcxiaoke/awesome-kotlin
• Kotlin-Koi: https://github.com/mcxiaoke/kotlin-koi
• Next公共组件库: https://github.com/mcxiaoke/Android-Next
• PackerNg极速打包: https://github.com/mcxiaoke/packer-ng-plugin
• Gradle渠道打包: https://github.com/mcxiaoke/gradle-packer-plugin
• EventBus实现xBus: https://github.com/mcxiaoke/xBus
• 蘑菇饭App: https://github.com/mcxiaoke/minicat
• 饭否客户端: https://github.com/mcxiaoke/fanfouapp-opensource
• Volley镜像: https://github.com/mcxiaoke/android-volley

---

rxdocs's Issues

6.3.1 Debounce翻譯問題

官方的原文only emit an item from an Observable if a particular timespan has passed without it emitting another item. 我覺得應該翻譯為僅在過了一段指定的時間才發射一個數據而不發射期間的數據。

從下面的diagram可以看出並不是仅在过了一段指定的时间还没发射数据时才发射一个数据的意思。

Create操作符问题

在 create 操作符中有这么一段描述
建议你在传递给 create 方法的函数中检查观察者的 isUnsubscribed 状态，以便在没有观察者
的时候，让你的Observable停止发射数据或者做昂贵的运算。
是不是可以理解为，在没有观察者的时候，被观察者依然会调用call方法并执行里边的操作？我编写了一段代码发现并没有执行啊是我的理解有错误吗？烦请解释下
代码如下

Observable observable1 = Observable.create(subscriber -> {
           subscriber.onNext(str);
            for (int i = 0; i < 10; i++) {
                Log.d("debug create","using call "+i);
            }
        });
//发现并没有调用

doOnSubscribe doOnUnsubscribe 描述错误

doOnUnsubscribe 操作符注册一个动作，当观察者取消订阅它生成的Observable它就会被调
用。
doOnSubscribe 操作符注册一个动作，当观察者订阅它生成的Observable它就会被调用。
描述错误啊。。
正常：
doOnUnsubscribe 操作符注册一个动作，当观察者取消订阅Observable，它就会被调
用。
doOnSubscribe 操作符注册一个动作，当观察者订阅Observable，它就会被调用。

Observables->创建观察者 章节翻译问题

Define a method that does something useful with the return value from the asynchronous call; this method is part of the observer.

目前的翻译为：
定义一个方法，它完成某些任务，然后从异步调用中返回一个值，这个方法是观察者的一部分。

更合理的翻译建议：
定义一个方法，这个方法拿着某个异步调用的返回值做一些有用的事情。这个方法是观察者的一部分。

RxJava2.0(升级) 部分的文档没有跟进更新

如题。

有没有2.0的介绍

关于ReactiveX简介这一章

今天查资料到Rx官网上逛了一圈，发现了一个很有意思的东西，在他们简介的页面新增了这样一段话

It is sometimes called “functional reactive programming” but this is a misnomer. ReactiveX may be functional, and it may be reactive, but “functional reactive programming” is a different animal. One main point of difference is that functional reactive programming operates on values that change continuously over time, while ReactiveX operates on discrete values that are emitted over time.

他们否认了Rx是“函数响应式编程”，对于这点应该怎么看？

首先感谢,大家的翻译,

不知道,大家考虑到,没有,文中对于方法使用 <操作符>来描述,对于,新接触的人来说,一时之间有点难以绕过弯,建议把操作符换成,方法,这样不是更容易理解吗!还有如何加入,这个翻译组,

RexactiveX中文文档修改意见

6.8节==>其他聚合操作符==>reduce( ) — 对序列使用reduce()函数并发射对吼的结果

其中“并发送对吼结果” 这句是否有问题？ 是不是应该改为“发射最终的结果”

Scan操作符 中的错误

Scan操作符会从第二项数据开始应用函数,当只有一个数据时不会应用函数。函数的第一个参数为第一项数据或上次函数的返回值，第二个参数为当前要处理的数据。

 Observable<Integer> scan = Observable.just(1,2,3,4,5).scan(new Func2<Integer, Integer, Integer>(){
            @Override
            public Integer call(Integer t1, Integer t2) {
                System.err.println("t1="+t1+"--t2="+t2);
                return t2+2;
            }

        });
        Subscriber subscriber = new Subscriber<T>(){
            @Override
            public void onStart() {
                System.err.println("onStart: ");
            }

            @Override
            public void onCompleted() {
                System.err.println("Completed!");
            }

            @Override
            public void onError(Throwable thrwbl) {
                System.err.println("Error!"+thrwbl.getMessage());
            }

            @Override
            public void onNext(T s) {
                System.err.println("Item: " +s.getClass()+"="+ s);
            }

        };
scan.subscribe(subscriber);

输出：

onStart: 
Item: class java.lang.Integer=1
t1=1--t2=2
Item: class java.lang.Integer=4
t1=4--t2=3
Item: class java.lang.Integer=5
t1=5--t2=4
Item: class java.lang.Integer=6
t1=6--t2=5
Item: class java.lang.Integer=7

timeout方法没有空参方法

timeout()
没有空参方法

连接操作这一章节中的refcount链接404

大小写错误导致404

为什么我找不到And/Then/When

RxJava更新到3.0都没看到这几个操作符

请求转载

我们建立了一个新的社区Kotlin China，请问能否让我们以精品专题形式，转载该项目下的文章。我们将标明原项目地址和作者和项目贡献者，同时期待您的加入。该项目地址， 服务使用kotlin编写构建

没看错这不是rxjava2？

新手。这不是rx2吧？

翻译错误

官方文档原文：

takeWhile( ) and takeWhileWithIndex( ) — emit items emitted by an Observable as long as a specified condition is true, then skip the remainder

文章当中的翻译：

takeWhile( ) and takeWhileWithIndex( ) — 发射原始Observable的数据，直到一个特定的条件为真，然后跳过剩余的数据

我认为应该翻译成-发射原始Observable的数据，只要这个条件为真，如果这个条件为假，那就跳过它及它之后剩余的数据。这里的 'as long as'是'只要'的意思，而不是'直到'。

测试代码：

Observable.just(1, 2, 3, 4, 5) .takeWhile(number -> number != 3) .subscribe(number -> System.out.println(number));
输出：
1 2

toIterable 描述错误

toFuture 操作符也是只能用于 BlockingObservable 。这个操作符将Observable转换为一
个 Iterable ，你可以通过它迭代原始Observable发射的数据集。

toFuture 操作符也是---->toIterable操作符也是

empty和error有一个可选参数是Scheduler?

但是我在1.1.0的版本并没有啊

图片丢了

这篇文章 https://github.com/mcxiaoke/RxDocs/blob/master/topics/Backpressure.md

另外谢谢你整理的文档！

RxJava 2.0版本翻译

2.0版本已经发布了，有没有计划对2.0进行翻译？

RxJAVA 使用示例 错别字

大概位置在 文末请看插图

应该为 “这一页“ 或者 “这一章节“ 的， 比较好吧

你好，我想问一下我在android项目中是用Rxjava还是用RxAndroid还是用Rxjava-android?麻烦了

这里有一个参数描述错误

doOnEach 操作符让你可以注册一个回调，它产生的Observable每发射一项数据就会调用它一
次。你可以以 Action 的形式传递参数给它，这个Action接受一个 onNext 的变
体 Notification 作为它的唯一参数，你也可以传递一个Observable给 doOnEach ，这个
Observable的 onNext 会被调用，就好像它订阅了原始的Observable一样。
Javadoc: doOnEach(Action1))
Javadoc: doOnEach(Observer))

你也可以传递一个Observer给 doOnEach,,, 这样才对啊，大神，印刷错误

RexactiveX中文文档修改意见

6.2.1章节中的buffer(bufferOpenings, bufferClosingSelector)小节里：
每当bufferOpenings发射了一个数据时，它就创建一个新的List开始手机原始Observable的数据，并将bufferOpenings传递给closingSelector函数。

手机二字编写错误