函数响应式编程基本特点
1、函数响应式编程
2、异步
3、事件驱动（事件作为可观察序列）
4、基于观察者模式
5、组合式
6、专门出错处理
7、适用于处理并发问题
基本概念
RxJava最核心的两个东西是Observables（被观察者，事件源）和Subscribers（观察者）。Observables发出一系列事件，Subscribers处理这些事件。这里的事件可以是任何你感兴趣的东西（触摸事件，web接口调用返回的数据。。。）
一个Observable可以发出零个或者多个事件，知道结束或者出错。每发出一个事件，就会调用它的Subscriber的onNext方法，最后调用Subscriber.onCompleted()或者Subscriber.onError()结束。
我们主要关心的是 onNext 函数来处理业务逻辑
基本使用实例
-
事件源发出一个字符串
Observable<String> observable = Observable.create(new OnSubscribe<String>() {@Override public void call(Subscriber<? super String> subscriber) { subscriber.onNext("hello rx android"); subscriber.onCompleted(); } });-
订阅着处理 onNext
Subscriber<String> subscriber = new Subscriber<String>() {@Override public void onCompleted() { Log.d(TAG, "onCompleted"); } @Override public void onError(Throwable e) { e.printStackTrace(); } @Override public void onNext(String t) { Log.d(TAG, t); } };
-
绑定事件和订阅者
observable.subscribe(subscriber);-
简单使用
Observable.just("hello rx Android 2").subscribe(new Action1<String>() { @Override public void call(String t) { Log.d(TAG, t); } });
轻量化
Observable只发出的事件
Subscribers只做事情是“响应”
操作符
操作符就是为了解决对Observable对象的变换的问题，操作符用于在Observable和最终的Subscriber之间修改Observable发出的事件
字符串拼接实例
Observable.just("hello rx Android 3")
.map(new Func1<String, String>() {
@Override
public String call(String t) {
return t + " map 操作赋";
}
})
.subscribe(new Action1<String>() {
@Override
public void call(String t) {
Log.d(TAG, t); //hello rx Android 3 map 操作赋
}
});
类型转换
Observable.just("hello rx Android 4")
.map(new Func1<String, Integer>() {
@Override
public Integer call(String t) {
return t.hashCode();
}
})
.subscribe(new Action1<Integer>() {
@Override
public void call(Integer t) {
Log.d(TAG, t + " = " + "hello rx Android 4".hashCode());
}
});
from方法
Observable.from()方法，它接收一个集合作为输入，然后每次输出一个元素给subscriber
Observable.from(new String[]{"hello rx Android 5", "hello rx Android 6"}).subscribe(new Action1<String>() {
@Override
public void call(String t) {
Log.d(TAG, t);//依次打印5， 6
}
});
flatMap
Observable.flatMap()接收一个Observable的输出作为输入，同时输出另外一个Observable
List<String> list = new ArrayList<String>();
list.add("hello rx Android 7");
list.add("hello rx Android 8");
Observable.just(list)
.flatMap(new Func1<List<String>, Observable<String>>() {
@Override
public Observable<String> call(List<String> t) {
return Observable.from(t);
}
})
.subscribe(new Action1<String>() {
@Override
public void call(String t) {
Log.d(TAG, t); // 依次打印7,8
}
});
filter 过滤
filter()输出和输入相同的元素，并且会过滤掉那些不满足检查条件的。
.filter(new Func1<String, Boolean>() {
@Override
public Boolean call(String t) {
return t != null;
}
})
take()
take()输出最多指定数量的
doOnNext()
doOnNext()允许我们在每次输出一个元素之前做一些额外的事情
List<String> list = new ArrayList<String>();
list.add("hello rx Android 7");
list.add("hello rx Android 8");
list.add(null);
Observable.just(list)
.flatMap(new Func1<List<String>, Observable<String>>() {
@Override
public Observable<String> call(List<String> t) {
return Observable.from(t);
}
})
.filter(new Func1<String, Boolean>() {
@Override
public Boolean call(String t) {
return t != null;
}
})
.take(2)
.doOnNext(new Action1<String>() {
@Override
public void call(String t) {
Log.e(TAG, t);
}
})
.subscribe(new Action1<String>() {
@Override
public void call(String t) {
Log.d(TAG, t);
}
});