通常而言，Rx如果遇到if条件语句、switch case语句时需要先选择分支条件，然后再进行链式调用。RxCondition产生的目的就是为了在这些情况下也能顺利地使用链式调用。
我在查找RxJava的条件、布尔操作符时，没有找到符合我需求的操作符。于是，我在网上找到了RxJavaComputationExpressions， 做了一些修改将RxJava1升级到RxJava2，增加了对Flowable的支持。
下载安装
下载地址：
https://github.com/fengzhizi715/RxCondition
使用方法：
1.ifThen用法
if条件语句传统的写法：
Observable<String> observable = null;
if (flag) {
observable = Observable.create(new ObservableOnSubscribe<String>() {
@Override
public void subscribe(@NonNull ObservableEmitter<String> e) throws Exception {
e.onNext("this is true");
}
});
} else {
observable = Observable.create(new ObservableOnSubscribe<String>() {
@Override
public void subscribe(@NonNull ObservableEmitter<String> e) throws Exception {
e.onNext("this is false");
}
});
}
observable.subscribe(new Consumer<String>() {
@Override
public void accept(@NonNull String s) throws Exception {
System.out.println("s="+s);
}
});
使用了ifThen()以后的写法：
Statement.ifThen(new BooleanSupplier() {
@Override
public boolean getAsBoolean() throws Exception {
return flag;
}
}, Observable.create(new ObservableOnSubscribe<String>() {
@Override
public void subscribe(@NonNull ObservableEmitter<String> e) throws Exception {
e.onNext("this is true");
}
}),Observable.create(new ObservableOnSubscribe<String>() {
@Override
public void subscribe(@NonNull ObservableEmitter<String> e) throws Exception {
e.onNext("this is false");
}
})).subscribe(new Consumer<String>() {
@Override
public void accept(@NonNull String s) throws Exception {
System.out.println("s="+s);
}
});
ifThen(BooleanSupplier condition, Observable<? extends R> then,Observable<? extends R> orElse)，其中第一个Observable是条件为true时执行的，第二个Observable则是条件为false时执行。
使用lambda表达式，进一步简化写法：
Statement.ifThen(()->{
return flag;
},Observable.create((e)->{
e.onNext("this is true");
}),Observable.create((e)->{
e.onNext("this is false");
})).subscribe((Consume) (s) -> {System.out.println("s="+s)});
当然，ifThen也支持Flowable：
Statement.ifThen(()->{
return flag;
},Flowable.just("this is true"), Flowable.just("this is false"))
.subscribe((Consume) (s) -> {System.out.println("s="+s)});
2.switchCase用法
switch case语句传统的写法：
Flowable<String> flowable = null;
switch(type) {
case 0:
flowable = Flowable.just("this is 0");
break;
case 1:
flowable = Flowable.just("this is 1");
break;
case 2:
flowable = Flowable.just("this is 2");
break;
case 3:
flowable = Flowable.just("this is 3");
break;
default:
flowable = Flowable.just("this is default");
break;
}
flowable.subscribe(new Consumer<String>() {
@Override
public void accept(@NonNull String s) throws Exception {
System.out.println("s="+s);
}
});
使用了switchCase()以后的写法：
Map<Integer,Flowable<String>> maps = new HashMap<>();
maps.put(0,Flowable.just("this is 0"));
maps.put(1,Flowable.just("this is 1"));
maps.put(2,Flowable.just("this is 2"));
maps.put(3,Flowable.just("this is 3"));
Statement.switchCase(new Callable<Integer>() {
@Override
public Integer call() throws Exception {
return type;
}
},maps,Flowable.just("this is default"))
.subscribe(new Consumer<String>() {
@Override
public void accept(@NonNull String s) throws Exception {
System.out.println("s="+s);
}
});
首先，将各个分支情况放入maps中。
其次，switchCase()的第一个参数是caseSelector，用于返回maps的key。最后一个参数是defaultCase，相当于switch case语句中的default语句。
改成lambda表达：
Map<Integer,Flowable<String>> maps = new HashMap<>();
maps.put(0,Flowable.just("this is 0"));
maps.put(1,Flowable.just("this is 1"));
maps.put(2,Flowable.just("this is 2"));
maps.put(3,Flowable.just("this is 3"));
Statement.switchCase((Callable)()-> {return type;},maps,Flowable.just("this is default"))
.subscribe((Consumer)(s) -> {System.out.println("s="+s);});
switchCase()中，第一个参数返回的是Map<K, R>中的key，它支持范型，所以switchCase()相对于switch case语句而已能够支持更多种类型。
原理
以ifThen为例，看看它某个方法是怎么运行的。
public static <R> Observable<R> ifThen(BooleanSupplier condition, Observable<? extends R> then,
Observable<? extends R> orElse) {
return RxJavaPlugins.onAssembly(new ObservableIfThen<R>(condition, then, orElse));
}
ifThen静态方法借助RxJavaPlugins.onAssembly()来生成一个新的Observable并返回。
ObservableIfThen是一个Observable的实现类。它的subscribeActual()方法是被订阅时真正执行的方法，用来衔接Observable和Observer(Subscriber)。在这里，subscribeActual()根据condition返回的bool值来判断是使用then还是使用orElse来做Observable。
import io.reactivex.Observable;
import io.reactivex.ObservableSource;
import io.reactivex.Observer;
import io.reactivex.functions.BooleanSupplier;
import io.reactivex.internal.disposables.EmptyDisposable;
/**
* Created by Tony Shen on 2017/5/9.
*/
final class ObservableIfThen<T> extends Observable<T> {
final BooleanSupplier condition;
final ObservableSource<? extends T> then;
final ObservableSource<? extends T> orElse;
ObservableIfThen(BooleanSupplier condition, ObservableSource<? extends T> then,
ObservableSource<? extends T> orElse) {
this.condition = condition;
this.then = then;
this.orElse = orElse;
}
@Override
protected void subscribeActual(Observer<? super T> observer) {
boolean b;
try {
b = condition.getAsBoolean();
} catch (Throwable ex) {
EmptyDisposable.error(ex, observer);
return;
}
if (b) {
then.subscribe(observer);
} else {
orElse.subscribe(observer);
}
}
}
switchCase的原理也是大同小异，区别在于订阅时需要根据key从map中取到对应的Observable/Flowable，取不到则使用defaultCase。
总结
这个库其实很简单，编写它的同时我加深了对RxJava中Observable/Flowable原理的认识。
