rxandroid

‘壹’ rxandroid onsubscribe什么时候调用

public class MainActivity extends AppCompatActivity {
Button btn;
TextView txt;

@Override
protected void onCreate(Bundle savedInstanceState) {
super.onCreate(savedInstanceState);
setContentView(R.layout.activity_main);
btn = (Button) findViewById(R.id.btn);
txt = (TextView) findViewById(R.id.txt);
txt.setVisibility(View.GONE);
btn.setOnClickListener(new View.OnClickListener() {
@Override
public void onClick(View v) {
test();
}
});
}

private String name0 = null;
private String name1 = null;
private String name2 = null;
private Handler handler = new Handler() {
@Override
public void handleMessage(Message msg) {
super.handleMessage(msg);
if (msg.what == 0) {
Toast.makeText(getApplicationContext(), name0, Toast.LENGTH_SHORT).show();
} else if (msg.what == 1) {
Toast.makeText(getApplicationContext(), name1, Toast.LENGTH_SHORT).show();
} else if (msg.what == 2) {
Toast.makeText(getApplicationContext(), name2, Toast.LENGTH_SHORT).show();
}
}
};

/**
* 如果在doOnSubscribe()之后指定了subscribeOn()，它决定了doOnSubscribe()在哪种线程中执行。
* （1）doOnSubscribe()之前的subscribeOn()不会影响它。
* （2）doOnSubscribe()之后的subscribeOn()，且是最近的才会影响它。
*/
private void test() {
Observable.create(new Observable.OnSubscribe<Integer>() {
@Override
public void call(Subscriber<? super Integer> subscriber) {
subscriber.onNext(2323);
name2 = "name2:" + Thread.currentThread().getName();
handler.sendEmptyMessage(2);
}
}).subscribeOn(AndroidSchelers.mainThread()) // 在doOnSubscribe()之前，不会影响上面的doOnSubscribe()
.doOnSubscribe(new Action0() {
@Override
public void call() {
name0 = "name0:" + Thread.currentThread().getName(); // 在子线程中执行
handler.sendEmptyMessage(0);
}
}).subscribeOn(Schelers.io()) // 会影响上面的doOnSubscribe()
.observeOn(Schelers.io())
.subscribeOn(AndroidSchelers.mainThread()) // 不会影响上面的doOnSubscribe()
.subscribe(new Action1<Integer>() {
@Override
public void call(Integer integer) {
name1 = "name1:" + Thread.currentThread().getName();
handler.sendEmptyMessage(1);
}
});
}
}

总结：在doOnSubscribe()之后，使用subscribeOn()就可以指定其运行在哪中线程。

‘贰’ rxandroid 生命周期什么时候调用

Dagger2：依赖注入并不是什么新技术，但是使用在Android确实一个新的尝试。AndroidApp越来越被当成严肃的大型项目来构建，很多在以前大型服务器开发上使用的技术都被应用到了移动开发。Android开发分模块开发，使用Dagger来松耦合模块。特别值得一体的是，Dagger2现在由Google亲自接管。Dagger‡。MVP：因为Android并没有严格的业务和界面区分，项目一复杂，就很容易使代码陷入混乱。现在Android开发社区对MVP模式讨论越来越热，觉得MVP是非常适合AndroidAPP开发。MVPforAndroid:。RxAndroid:函数响应式编程（FunctionalReactiveProgramming）也不是新内容，RxAndroid把Rxjava带到Android环境中。很多时候，编写Android程序，你也可以看成是数据的处理和流动，换一种思想编程，曾经看起来很棘手的问题，瞬间就很优雅的解决了：ReactiveX/RxAndroid。MVVM：这是因为开始官方支持DataBinding，把MVVM直接带到Android中。数据绑定在WindowsWPF和Web已经非常常见，它非常高效的开发效率，让你只关心你的数据和业务。这也对Android开发来说，无疑是一个非常重大的影响：androidUI设计MVVM设计模式讨论？。插件化：针对大型Android项目，很多App开始使用插件来分模块构建相对独立的功能。Hybrid：完全使用HTML5开发App，目前还不成熟。但是折中方案在很多情况下是非常适合的，典型的就是微信，大部分信息展示都是通过H5来完成，同时通过Hybird方式，把Web和Native打通，提供给网页访问本地资源的能力。

‘叁’ rxandroid和rxjava的区别

RxJava要比EventBus的应用更广泛，EventBus仅仅是作为一种消息的传递工具，但是RxJava里面几乎可以做任何事情。

如果是Android开发的话，可以使用RxAndroid，这是对RxJava的一个扩展，结合sqare公司的retrofit可以很轻松的完成网络的访问。

我们知道，在Android中异步操作一般使用AsycTask来完成，但是AsycTask有很多缺点，如不能方便的终止任务的执行等。

RxAndroid完全可以替代AsycTask来完成各种异步操作，而且还有BindActivity和BindFragment方法，你根本不需要考虑异步操作时的Activity和Fragment的生命周期问题，还有更加强大的的链式调用，可以使程序很简洁。

EventBus有个缺点就是凡是使用了EventBus的类都不能进行混淆了，否则Evnetbus就找不到OnEvent方法了。

以上，推荐使用RxAndroid。

‘肆’ rxandroid和volley哪个好用

两个不一样的东西。rx是响应式编程，让代码更有条理性，针对复杂逻辑来说很好用。volley是谷歌官方出来的网络框架，针对大量的小数据请求应用。

‘伍’ 谁来讲讲Rxjava，rxandroid中的操作符的作用

1.去官网大致看一遍各个操作符2.部分区分不清（比如map与flatmap）的面向github或者stackoverflow找答案，用英文哦，否则会被网络与CSDN的渣文章给扰乱3.去github等社区找android示例，比如GitHub-lzyzsd/Awesome-RxJava:RxJavaresour

‘陆’ 谁来分享一下RxJava，RxAndroid，RxBind，RxBus

1. 去官网大致看一遍各个操作符
2. 部分区分不清（比如map与flatmap）的面向github或者stackoverflow找答案，用英文哦，否则会被网络与CSDN的渣文章给扰乱
3. 去github等社区找android示例，比如 GitHub - lzyzsd/Awesome-RxJava: RxJava resources
4. 自己去写实际项目或者编程题，比如去oj平台（比如newcoder）用rxjava做编程题，这个非常有助于加深对流程化与可观察的理解。虽然平台上不可能用第三方lib，但是自己只用rxjava写出来并与原来算法进行对比（代码量与可读性）即可，最后整理成笔记博客等进行保存。

‘柒’ rxandroid 是怎么实现子线程和主线程通信

android里线程间通信，到现在我看到的实现都是用Handler，RxAndroid也不例外。

‘捌’ rxandroid对rxjava做了哪些优化

ReactiveX的每种编程语言的实现都实现了一组操作符的集合。不同的实现之间有很多重叠的部分，也有一些操作符只存在特定的实现中。每种实现都倾向于用那种编程语言中他们熟悉的上下文中相似的方法给这些操作符命名。
本文首先会给出ReactiveX的核心操作符列表和对应的文档链接，后面还有一个决策树用于帮助你根据具体的场景选择合适的操作符。最后有一个语言特定实现的按字母排序的操作符列表。
如果你想实现你自己的操作符，可以参考这里：实现自定义操作符
创建操作
用于创建Observable的操作符
Create — 通过调用观察者的方法从头创建一个Observable
Defer — 在观察者订阅之前不创建这个Observable，为每一个观察者创建一个新的Observable
Empty/Never/Throw — 创建行为受限的特殊Observable
From — 将其它的对象或数据结构转换为Observable
Interval — 创建一个定时发射整数序列的Observable
Just — 将对象或者对象集合转换为一个会发射这些对象的Observable
Range — 创建发射指定范围的整数序列的Observable
Repeat — 创建重复发射特定的数据或数据序列的Observable
Start — 创建发射一个函数的返回值的Observable
Timer — 创建在一个指定的延迟之后发射单个数据的Observable