[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