nanchen2251/rxjava2examples

:fire:RxJava2 Examples —— 这可能是从 RxJava1 跳到 RxJava2（学习 RxJava2 ）最好的例子 Demo：https://github.com/nanchen2251/RxJava2Examples

RxJava2Examples

RxJava2 Examples——它可能是从RxJava1跳到RxJava2（学习RxJava2）最好的例子Demo

RxJava 1.x 到 RxJava 2.x 的无缝对接
无需学习 RxJava 1.x, 直接学习 RxJava 2.x
完备齐全的操作符示例
支持与 Retrofit 交互处理示例
Activity 基类封装处理

文章链接：

这可能是最好的 RxJava 2.x 入门教程（完结版）
这可能是最好的 RxJava 2.x 入门教程（一）
这可能是最好的 RxJava 2.x 入门教程（二）
这可能是最好的 RxJava 2.x 入门教程（三）
这可能是最好的 RxJava 2.x 入门教程（四）
这可能是最好的 RxJava 2.x 入门教程（五）

关于作者

   南尘
   四川成都
   其它开源
   个人博客
   简书
   博客园
   交流群：118116509 ( 点击图标即可加入 )
   欢迎投稿(关注)我的唯一公众号，公众号搜索 nanchen 或者扫描下方二维码：
   

Just a gif

RxJava 1.x 到 RxJava 2.x 变化一览

RxJava 1.x -> RxJava 2.x

• onCompleted -> onComplete - without the trailing d
• Func1 -> Function
• Func2 -> BiFunction
• CompositeSubscription -> CompositeDisposable
• limit operator has been removed - Use take in RxJava2
• and much more.

一些操作符的解释

• Map -> transform the items emitted by an Observable by applying a function to each item
• Zip -> combine the emissions of multiple Observables together via a specified function and emit single items for each combination based on the results of this function
• Filter -> emit only those items from an Observable that pass a predicate test
• FlatMap -> transform the items emitted by an Observable into Observables, then flatten the emissions from those into a single Observable
• Take -> emit only the first n items emitted by an Observable
• Reduce -> apply a function to each item emitted by an Observable, sequentially, and emit the final value
• Skip -> suppress the first n items emitted by an Observable
• Buffer -> periodically gather items emitted by an Observable into bundles and emit these bundles rather than emitting the items one at a time
• Concat -> emit the emissions from two or more Observables without interleaving them
• Replay -> ensure that all observers see the same sequence of emitted items, even if they subscribe after the Observable has begun emitting items
• Merge -> combine multiple Observables into one by merging their emissions

尽情地下载运行，开始感受RxJava 2.x 的强大魅力吧~

为这个例子pull你的伟大代码，加入分享这个大家庭，Just to do!

该例子借鉴了以下项目：

• https://github.com/amitshekhariitbhu/RxJava2-Android-Samples

   

有码走遍天下 无码寸步难行（引自网络）

1024 - 梦想，永不止步!
爱编程 不爱Bug
爱加班 不爱黑眼圈
固执 但不偏执
疯狂 但不疯癫
生活里的菜鸟
工作中的大神
身怀宝藏，一心憧憬星辰大海
追求极致，目标始于高山之巅
一群怀揣好奇，梦想改变世界的孩子
一群追日逐浪，正在改变世界的极客
你们用最美的语言，诠释着科技的力量
你们用极速的创新，引领着时代的变迁

------至所有正在努力奋斗的程序猿们！加油！！

Licenses

 Copyright 2017 nanchen(刘世麟)

 Licensed under the Apache License, Version 2.0 (the "License");
 you may not use this file except in compliance with the License.
 You may obtain a copy of the License at

      http://www.apache.org/licenses/LICENSE-2.0

 Unless required by applicable law or agreed to in writing, software
 distributed under the License is distributed on an "AS IS" BASIS,
 WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
 See the License for the specific language governing permissions and
 limitations under the License.

rxjava2examples's Issues

Rxjava 2.0 怎么混淆 找不到

接口好像都用不了了。。。^_^

接口好像都用不了了。。。^_^

RxIntervalActivity and RxTimerActivity throw exception please add under code, thank you.

.subscribeOn(Schedulers.newThread())
.observeOn(AndroidSchedulers.mainThread())

接口挂了

http://www.tngou.net/api/food/list 里面的api接口挂了 0.0

What's the different between Observable.merge & Observable.merge ?

关于Map转换return null的问题

我在你的文章这可能是最好的RxJava 2.x 入门教程（五）中发现有这样一段代码。

.map(new Function<Response, MobileAddress>() {
                    @Override
                    public MobileAddress apply(@NonNull Response response) throws Exception {

                        Log.e(TAG, "map 线程:" + Thread.currentThread().getName() + "\n");
                        if (response.isSuccessful()) {
                            ResponseBody body = response.body();
                            if (body != null) {
                                Log.e(TAG, "map:转换前:" + response.body());
                                return new Gson().fromJson(body.string(), MobileAddress.class);
                            }
                        }
                        return null;
                    }
                })

Rxjava2现在不是严格不许传null的吗？我以前也是想你这样写的，传入一个泛型，将服务器的数据转换成我要的泛型返回。结果服务器给我传了一个null，直接就奔溃了，他会直接报异常“The mapper function returned a null value”，我也在Rxjava的Github提过，他们给我的反馈就是RxJava2跟RxJava1不同，是严禁任何null的

接口用不了了

关于合并操作符的使用问题

你好 关于一些合并操作符有一个问题 就说zip
场景如下 我有两个接口需要访问，但是呢 如果两个接口都抛异常了(如果只是一个接口抛异常 就会走onError里，如果都抛异常，一个会走，一个就抛异常) 那rxjava就会报at io.reactivex.plugins.RxJavaPlugins.onError(RxJavaPlugins.java:366) 版本是2.0.1
实在想不到解决方法 应该是使用方式不对 请指教

flatMap例子中控件可以显示出完整信息，logcat中会偶尔缺少是怎么回事？

flatMap例子中控件可以显示出完整信息，logcat日志中会偶尔缺少几条数据是怎么回事？