RxJava的观察者类有许多方法，可以转换发出的字节流为任何你需要的数据类型。这些方法是RxJava非常核心的方法，是RxJava具有吸引力的重要缘故。但是有些方法无论如何都不能改变流本身，我称这些方法为副作用(Side Effect)方法。关于副作用方法，我的一点观点副作用方法并不影响你的字节流本身。相反地，当某些事件发生时它们被调用，这样允许你去处理这些事件。举个例子：当一些错误发生了，如果你想在你的订阅者回调函数之外做些处...
开发中多次碰到了tolist方法阻塞住的问题。一直为了赶进度，避开使用该操作符号。直到有一天发现flatmap中的 observable.from()也会阻塞。排查原因才发现是 onComplete()方法没有调用的原因。根据rxjava的链式调用原理，有从下到上一步步传递回调函数，在从上到下逐步执行的过程。而该过程中有的步骤执行需要等待oncomplete调用。 Rxjava 执行阻塞的原因分析 tolist() observable.from()等。原文：http://www.cnblogs.com/ep...
RxJava在现在是一个非常前卫的异步框架，也是由于他非常新，所以比较难以驾驭。 像okhttp直接在onStop或者onDestroy 调用它的cancel方法就行了，但是Rxjava并没有那么简单。因为假如每次请求都得到Observable对象，然后再onStop中unsubscribe取消，这样很不利于封装。而且会造成代码量很多，所以我找到了用rxlifecycle的解决方案。 先导包 compile ‘com.trello:rxlifecycle:0.5.0‘compile ‘com.trello:rxlifecycle-compone...
关键词：合并 Observable前言在RxJava中， 同时处理多个Observables是很常见的一种操作。下面我们简单分析下几个组合类的操作符。如果你不想看操作符的介绍，可以直接跳到项目实战部分。Merge在异步的世界经常会创建这样的场景，我们有多个来源但是只想有一个结果：多输入，单输出。RxJava的merge()方法将帮助你把两个甚至更多的Observables合并到他们发射的数据里。下图给出了把两个序列合并在一个最终发射的Observable。正如你看...
1、RxJava 项目地址 https://github.com/ReactiveX/RxJava 2、RxAndroid 项目地址 https://github.com/ReactiveX/RxAndroid 3、RxJava 和 RxAndroid 的关系 RxAndroid是RxJava的一个针对Android平台的扩展，主要用于 Android 开发 4、RxJava和EventBus的区别？ https://www.zhihu.com/question/32179258/answer/54989242 5、RxAndroid的使用方法 compile ‘io.reactivex:rxandroid:1.1.0‘ 6、如何查看RxAndroid...
本文出处 :Tamic 文/ http://blog.csdn.net/sk719887916/article/details/52132106Rxjava +Rterofit 需要掌握的几个技巧RXjava入门和详解请移步 比较有名的《RxJAVA详解》，这里继续前篇一些列的介绍一些容易忽略的技巧.Retrofit+RxJava结合系列请阅读：Retrofit 2.0 超能实践，完美支持Https传输Retrofit2.0 完美同步Cookie实现免登录Retrofit 2.0 超能实践（三），轻松实现文件/图片上传-Retrofit 2.0 超能实践（四），完成大文件...
1. RxJava采用了观察者模式，什么是观察者模式呢，能不能举个例子？答：小偷（被观察者）把手伸进路人的钱包后（事件），给警察（观察者）发了条短信，曰：快来抓我哟！警察收到信息后，立马采取行动，把小偷按倒在地（行动）这个小偷是不是很贱，偷东西还要告诉警察2. 一个语文作业题：分析下面这句话的主、谓、宾 observable.subscribe(observer)答： - 主语：observable 被观察者 - 谓语：subscribe 订阅 - 宾语：observer 观...
在第一篇blog中，我介绍了RxJava的一些基础知识，同时也介绍了map()操作符。当然如果你并没有意愿去使用RxJava我一点都不诧异，毕竟才接触了这么点。看完这篇blog，我相信你肯定想立即在你的项目中使用RxJava了，这篇blog将介绍许多RxJava中的操作符，RxJava的强大性就来自于它所定义的操作符。 首先先看一个例子：准备工作 假设我有这样一个方法： 这个方法根据输入的字符串返回一个网站的url列表（啊哈，搜索引擎）Observable<Li...
RxJava用了快半年了，现在越来越离不开这个库，从使用到逐渐接触它的背后实现，突然想写点什么关于RxJava的内容。在酝酿如何组织内容的时候，就去看看自己关于RxJava的收藏，发现满满的干货！1.抛物线:给 Android 开发者的 RxJava 详解，我的RxJava入门老师，从原理到用法到实现，面面俱到，非常nice！2.hi大头鬼hi：深入浅出RxJava（一：基础篇），这是篇翻译文章，偏重用使用RxJava，对于操作符的讲解还不错，值得一看。3.RxJava...
和Retrofit2单独使用有一些区别首先，同样写个interface，这里是GitHubService.java，我们这次要实现获取官方提供的测试接口的数据1publicinterface GitHubService { 2 @GET("repos/{owner}/{repo}/contributors") 3 Observable<List<Contributor>> getUserInfoByObservable(@Path("owner") String owner, @Path("repo") String repo); 4 }注意，上边的区别，retrofit2单独使用的时候是Call<List<Contributor>>，而rx使用的...
原文出自《RxJava Essentials》原文作者 : Ivan Morgillo译文出自 : 开发技术前线 www.devtf.cn转载声明: 本译文已授权开发人员头条享有独家转载权，未经同意。不得转载!译者 : yuxingxin项目地址 : RxJava-Essentials-CN向响应式世界问好在上一章中，我们对观察者模式有个理论上的高速概述。我们也看了从头開始、从列表、或者从已经存在的函数来创建Observables。在本章中。我们将用我们学到的来创建我们第一个响应式Android应用程...
原文出自《RxJava Essentials》原文作者 : Ivan Morgillo译文出自 : 开发技术前线 www.devtf.cn转载声明: 本译文已授权开发者头条享有独家转载权，未经允许，不得转载!译者 : yuxingxin项目地址 : RxJava-Essentials-CNRX - 从.NET到RxJava响应式编程是一种基于异步数据流概念的编程模式。数据流就像一条河：它可以被观测，被过滤，被操作，或者为新的消费者与另外一条流合并为一条新的流。响应式编程的一个关键概念是事件。事件可...
publicclass RestApi { public static String BASE_URL = "http://202.108.31.64:9080/api/v2.0/";publicstatic String API_SERVER_ADDR = "ApiServerAddr";publicstatic String API_SERVER_PORT = "ApiServerPort";publicstatic String DEF_SERVER_PORT = "";publicstatic String MQTT_BROKER = "tcp://" + DEF_SERVER_ADDR + ":1883";privatestatic Retrofit retrofit;privatestatic RestService restService;publicstaticvoid ...
RxJava与EventBus的区别RxJava订阅与发布事件不是分开写的，是函数式编程。指定发布事件和消费事件的方式不一样，RxJava直接通过2个方法指定，而EventBus需要单独的定义方法。RxJava比EventBus更加地强大：a)变换： 对于发布的事件的数据，RxJava可以拦截进行转换，XxxMap这样的方法中添加FunX类的call方法（闭包） map变换 flatMap变换 序列变换 b)RxJava与Retrofit，可以实现网络请求的嵌套操作。...
这可能是最好的RxJava 2.x入门教程系列专栏文章链接：这可能是最好的RxJava 2.x 入门教程（一）这可能是最好的RxJava 2.x 入门教程（二）这可能是最好的RxJava 2.x 入门教程（三）GitHub 代码同步更新：https://github.com/nanchen2251/RxJava2Examples为了满足大家的饥渴难耐，GitHub将同步更新代码，主要包含基本的代码封装，RxJava 2.x所有操作符应用场景介绍和实际应用场景，后期除了RxJava可能还会增添其他东西，总之，GitHub...