添加依賴（注意是rxjava1 不是rxjava2 ＞鹾ＤɑΑ）
compile 'io.reactivex:rxjava:1.3.0'
compile 'io.reactivex:rxandroid:1.2.1'
一纵菌。 基本使用
- 首先新建被觀察者
//被觀察者
Observable<String> observable = Observable.create(new Observable.OnSubscribe<String>() {
@Override
public void call(Subscriber<? super String> subscriber) {
subscriber.onNext("this is a message 1");//發(fā)送第一條信息
subscriber.onNext("this is a message 2");//發(fā)送第二條信息
subscriber.onCompleted();//發(fā)送完成
}
});
- 訂閱者
Subscriber<String> subscriber = new Subscriber<String>() {
@Override
public void onCompleted() {
//全部接受完回調(diào)
Log.i(TAG, "onCompleted: ");
}
@Override
public void onError(Throwable e) {
//錯誤的回調(diào)
Log.i(TAG, "onError: " + e.getMessage());
}
@Override
public void onNext(String o) {
//接受單條數(shù)據(jù)
Log.i(TAG, "onNext: " + o);
Toast.makeText(MainActivity.this, o, Toast.LENGTH_SHORT).show();
}
};
3.訂閱關(guān)系
//訂閱關(guān)系
observable.subscribe(subscriber);//添加訂閱者
運行下(上面全部放到activity oncreate方法中就行了)洋闽，這就是最基本的使用了玄柠，是不是很簡單呢
二：耗時操作，RxJava本來就是處理異步的 而且特別簡單
添加耗時操作诫舅，上面 被觀察者代碼中 增加就行
try {
Thread.sleep(9000);//模擬耗時操作羽利，網(wǎng)絡(luò)請求
} catch (InterruptedException e) {
e.printStackTrace();
}
subscriber.onNext("this is a message 1");
subscriber.onNext("this is a message 2");
subscriber.onCompleted();
現(xiàn)在直接運行肯定會ANR的。刊懈。
很簡單 铐伴，只需要修改下訂閱關(guān)系：
observable.subscribeOn(Schedulers.io())//訂閱者運行在子線程
.observeOn(AndroidSchedulers.mainThread())//Toast回到主線程
.subscribe(subscriber);
怎么樣？是不是不需要Handler發(fā)過來發(fā)過去了俏讹。当宴。。
這是最原始的用法泽疆，下面開始精簡用法
三户矢。 精簡使用
針對上面第一個的簡單實現(xiàn)
String[] values = {"this is a message 1", "this is a message 2"};//定義一個數(shù)組
Observable.from(values)
.subscribe(new Subscriber<String>() {
@Override
public void onCompleted() {}
@Override
public void onError(Throwable e) {}
@Override
public void onNext(String s) {
Toast.makeText(MainActivity.this, s, Toast.LENGTH_SHORT).show();
}
});
當(dāng)然，還可以更簡單
String[] values = {"this is a message 1", "this is a message 2", "this is a message 3"};
Observable.from(values)
.subscribe(new Action1<String>() {
@Override
public void call(String s) {
Toast.makeText(MainActivity.this, s, Toast.LENGTH_SHORT).show();
}
});
怎么殉疼？還不夠簡潔梯浪，再來！
String[] values = {"this is a message 1", "this is a message 2", "this is a message 3"};
Observable.from(values)
.subscribe(s -> Toast.makeText(MainActivity.this, s, Toast.LENGTH_SHORT).show());//lambda表達(dá)式形式
這已經(jīng)是最簡單了瓢娜。挂洛。。
關(guān)于lambda語法眠砾，自己看下吧 特備簡單虏劲，就是一些縮寫而已，
AS需要配置 ：https://github.com/evant/gradle-retrolambda
最后附一個 過濾非偶數(shù)褒颈，并乘以2柒巫，轉(zhuǎn)換成String類型，輸出的例子(lambda語法形式)
Integer[] values = {1, 3, 4, 7, 8};
Observable.from(values)
.filter(integer -> integer % 2 == 0)//過濾非偶數(shù)
.scan((integer, integer2) -> integer2 * 2)//函數(shù)*2
.map(value -> value + "")//轉(zhuǎn)換string格式
.subscribeOn(Schedulers.io())//調(diào)度器分配線程
.observeOn(AndroidSchedulers.mainThread())//回到主線程
.subscribe(s -> Log.i(TAG, "test:--- " + s));//打印日志
................................END...............................
