導語
神父，我懺悔，作為一個Android開發(fā)，對于RxJava還是一無所知。最初知道他的名字大概是前年？群里一大神用RxJava搞事情，當初并不知道這有什么卵用。再一次知道是在去年，書簽里保存了很多關于它的文章，但是一直都沒看過 = = 以上。
吶，開始，先別jier跟我整些有的沒的，我就是想先用用感受下。
- 添加依賴，順手加上butterknife
compile 'io.reactivex.rxjava2:rxjava:2.1.1'
compile 'io.reactivex.rxjava2:rxandroid:2.0.1'
compile 'com.jakewharton:butterknife:8.7.0'
annotationProcessor 'com.jakewharton:butterknife-compiler:8.7.0'
- 強擼代碼
@OnClick(R.id.btn)
public void onClick() {
//創(chuàng)建被觀察者
Observable observable = Observable.create(new ObservableOnSubscribe<String>() {
@Override
public void subscribe(@NonNull ObservableEmitter<String> e) throws Exception {
e.onNext("第一發(fā)");
e.onNext("第二發(fā)");
e.onNext("第三發(fā)");
e.onComplete();
}
});
//創(chuàng)建一個觀察者
Observer<String> observer = new Observer<String>() {
@Override
public void onSubscribe(@NonNull Disposable d) {
Log.e("rxjava","Disposable是個什么玩意");
}
@Override
public void onNext(@NonNull String s) {
Toast.makeText(MainActivity.this, s, Toast.LENGTH_SHORT).show();
}
@Override
public void onError(@NonNull Throwable e) {
}
@Override
public void onComplete() {
Log.e("rxjava","onComplete");
}
};
//連接 被觀察者看上去很主動的請求觀察者連接他，很棒棒？
observable.subscribe(observer);
}
??OKOK，運行下，沒毛病。先執(zhí)行onSubscribe，然后next依次執(zhí)行，最后執(zhí)行onComplete。可以腦補了，onSubscribe開始工作的時候調(diào)用，onNext干活，onError罷工，onComplete工作完成。試一下onError好了。
@OnClick(R.id.btn)
public void onClick() {
//創(chuàng)建被觀察者
Observable observable = Observable.create(new ObservableOnSubscribe<String>() {
@Override
public void subscribe(@NonNull ObservableEmitter<String> e) throws Exception {
e.onNext("第一發(fā)");
e.onNext("第二發(fā)");
e.onNext(null);
e.onNext("第三發(fā)");
e.onComplete();
}
});
//創(chuàng)建一個觀察者
Observer<String> observer = new Observer<String>() {
@Override
public void onSubscribe(@NonNull Disposable d) {
Log.e("rxjava","Disposable是個什么玩意");
}
@Override
public void onNext(@NonNull String s) {
Toast.makeText(MainActivity.this, s.toString(), Toast.LENGTH_SHORT).show();
}
@Override
public void onError(@NonNull Throwable e) {
Log.e("rxjava","onError");
}
@Override
public void onComplete() {
Log.e("rxjava","onComplete");
}
};
//連接 被觀察者看上去很主動的請求觀察者連接他，很棒棒？
observable.subscribe(observer);
}
改了下代碼
??執(zhí)行順序分別是onSubscribe--toast1-toast2-onError沒了，onComplete在工作成果完成后調(diào)用?？梢赃@很科學。
??排下版弄成傳說中的鏈式結(jié)構(gòu)。
@OnClick(R.id.btn)
public void onClick() {
Observable.create(new ObservableOnSubscribe<String>() {
@Override
public void subscribe(@NonNull ObservableEmitter<String> e) throws Exception {
e.onNext("第一發(fā)");
e.onNext("第二發(fā)");
e.onNext(null);
e.onNext("第三發(fā)");
e.onComplete();
}
}).subscribe(new Observer<String>() {
@Override
public void onSubscribe(@NonNull Disposable d) {
Log.e("rxjava", "Disposable是個什么玩意");
}
@Override
public void onNext(@NonNull String s) {
Toast.makeText(MainActivity.this, s.toString(), Toast.LENGTH_SHORT).show();
}
@Override
public void onError(@NonNull Throwable e) {
Log.e("rxjava", "onError");
}
@Override
public void onComplete() {
Log.e("rxjava", "onComplete");
}
});
}
??沒毛病，用著還算闊以，想想在什么情況下會用到呢，目前只想到排隊送死流會用到了。看上去每次都要傳遞相同類型的參數(shù)過去？還是在onNext里面強轉(zhuǎn)？那豈不是變墨跡了？這個坑先放著，基礎體位這就用完了？好空虛，好寂寞。
- ObservableEmitter biubiubiu的發(fā)射器
??可以發(fā)射三種導彈，No.1:onNext,No.2:onComplete,No.3:onError。恩，繼續(xù)
我擦，原來三種導彈是可以隨便發(fā)的，沒啥順序要求，我還以為必須按順序來呢，這很靈活啊。上游可以隨便biubiubiu,無論如何都會把事件執(zhí)行完，下游遇到成功或者失敗的指令就會停止不在聽上游瞎jierBB。開發(fā)者自己控制成功失敗的執(zhí)行，而且也可以不發(fā)射這兩種導彈。當然成功和失敗是互斥的，值得注意的是多次發(fā)射成功沒啥事，但是收到兩次失敗的話，程序會瞬間爆炸崩潰。
-Disposable 功能一：導彈攔截裝置
@OnClick(R.id.btn)
public void onClick() {
Observable.create(new ObservableOnSubscribe<String>() {
@Override
public void subscribe(@NonNull ObservableEmitter<String> e) throws Exception {
e.onNext("第一發(fā)");
e.onNext("第二發(fā)");
e.onNext("第三發(fā)");
e.onNext("第四發(fā)");
e.onComplete();
}
}).subscribe(new Observer<String>() {
private Disposable disposable;
private int i;
@Override
public void onSubscribe(@NonNull Disposable d) {
disposable = d;
}
@Override
public void onNext(@NonNull String s) {
Toast.makeText(MainActivity.this, s.toString(), Toast.LENGTH_SHORT).show();
i++;
if (i == 2) {
disposable.dispose();
}
}
@Override
public void onError(@NonNull Throwable e) {
Log.e("rxjava", "onError");
}
@Override
public void onComplete() {
Log.e("rxjava", "onComplete");
}
});
}
??運行下，大概的意思是，上游一直在那里BB，然后：發(fā)你妹啊，看我直接把你掐死。當然上游依舊我行我素，只不過是下游不叼他了。
PS：原來是可以這么記數(shù)的，制杖了。
- subscribe() 厚道的重載方法，拷貝忍者汪汪卡覲見
public final Disposable subscribe() {}
public final Disposable subscribe(Consumer<? super T> onNext) {}
public final Disposable subscribe(Consumer<? super T> onNext, Consumer<? super Throwable> onError) {}
public final Disposable subscribe(Consumer<? super T> onNext, Consumer<? super Throwable> onError, Action onComplete) {}
public final Disposable subscribe(Consumer<? super T> onNext, Consumer<? super Throwable> onError, Action onComplete, Consumer<? super Disposable> onSubscribe) {}
public final void subscribe(Observer<? super T> observer) {}
不帶參數(shù)：你上游可勁BB，老紙不管
帶參數(shù)：你BB我做就好了，并不在意成功與失敗
Over 請問，沒有“個性”的人也能夠成為英雄嗎？
One·for·All
