[RxJava^Android]项目经验分享 --- 递归实现

介绍一下业务逻辑：获取接口数据，根据接口内容判断是否须要继续获取数据。
本文使用递归思路，经过RxJava来实现此功能，获取数据的Observable直接用模拟的Observable.just()替代。关键点使用concatMap和concatWith操做符

代码块

public Observable<Integer> getInt(int i) {
    return Observable.just(i).concatMap(integer -> {
        if (integer == 10) {  //判断条件
            return Observable.just(10); //发射数据
        } else {
            return Observable
                    .just(integer)
                    .concatWith(getInt(integer + 1));
                    //链接发射
        }
    });
}

public void testMain() {
        getInt(0).subscribe(getSubscriber());
}

private Subscriber<Object> getSubscriber() {
    return new Subscriber<Object>() {
        @Override
        public void onCompleted() {
            LogUtils.d("onCompleted");
        }
        
        @Override
        public void onError(Throwable e) {
            LogUtils.d("onError : " + e.toString());
        }
        
        @Override
        public void onNext(Object o) {
            LogUtils.d("onNext : " + o);
        }
    };
}

输出结果

01-05 10:42:13.257 24959-24975/? D/LogUtils: onNext : 0
01-05 10:42:13.257 24959-24975/? D/LogUtils: onNext : 1
01-05 10:42:13.257 24959-24975/? D/LogUtils: onNext : 2
01-05 10:42:13.257 24959-24975/? D/LogUtils: onNext : 3
01-05 10:42:13.257 24959-24975/? D/LogUtils: onNext : 4
01-05 10:42:13.258 24959-24975/? D/LogUtils: onNext : 5
01-05 10:42:13.258 24959-24975/? D/LogUtils: onNext : 6
01-05 10:42:13.258 24959-24975/? D/LogUtils: onNext : 7
01-05 10:42:13.258 24959-24975/? D/LogUtils: onNext : 8
01-05 10:42:13.258 24959-24975/? D/LogUtils: onNext : 9
01-05 10:42:13.258 24959-24975/? D/LogUtils: onNext : 10
01-05 10:42:13.258 24959-24975/? D/LogUtils: onCompleted