RxJava - 在第一个是有条件的情况下进行两次调用

Question

我正在使用 RxJava 2 进行 API 调用。 我必须打电话取消课程的预订。

但我必须先打一个电话才能获得丢失的信息。

是这样的：

if classId not exists
   get classId
   then unbook class
else
   unbook class

我不想重复取消预订课程代码。

这里是简化的代码：

FitnessDataService service = RetrofitInstance.getRetrofitInstance().create(FitnessDataService.class);
        // if we don't have the aid of class (reserved), we get it from the reserved classes


        if (fitClass.getAid() == null) {
            service.getReservedClasses(FitHelper.clientId)
                    .flatMap(reservedClasses ->
                    {
                        // get the class ID from reserved classes
                         ...
                        return service.unbookClass(fitClass.getAid());
                    }).subscribeOn(Schedulers.io())
                    .observeOn(AndroidSchedulers.mainThread())
                    .subscribe(response -> {
                                // success
                            }, err -> 
                                // error
        } else {
            service.unbookClass(fitClass.getAid())
                    .subscribeOn(Schedulers.io())
                    .observeOn(AndroidSchedulers.mainThread())
                    .subscribe(response -> {
                                // success
                            }, err -> 
                                // error
        }

如您所见，service.unbookClass 是重复的。 如果我没有类 ID（fitClass.getAid() == null），我如何始终调用这个 service.unbookClass 并且只调用 service.getReservedClasses 无需将代码重复到第二次调用。

Answer 1

我建议将 id 的实际来源分离到它自己单独的 observable 中。可能是这样的：

Observable<Long> idObservable;
if (fitClass.getAid() == null) {
    idObservable = service.getReservedClasses(FitHelper.clientId)
        .map({ reservedClasses ->
            /* Get the Id and do stuff with it */
            return fitClass.getAid();
        });
} else {
    idObservable = Observable.just(fitClass.getAid());
}

idObservable.flatMap({ aid -> service.unbookClass(aid) })
    .subscribeOn(Schedulers.io())
    .observeOn(AndroidSchedulers.mainThread())
    .subscribe(/* TODO */);

Answer 2

Maybe 和 switchIfEmpty 看起来很适合。 fromCallable 方法如果返回值非空，则返回 1 值，如果返回的项是 null，则完成。如果源没有发出项目，switchIfEmpty 可用于提供替代（在这种情况下为 Single 或 Maybe）。假设您对 unbookClass 的改造调用返回一个单，您的代码将类似于 --

Maybe.fromCallable(() -> fitClass.getAid())
    .switchIfEmpty(service.getReservedClasses(FitHelper.clientId)
                    .flatMap(reservedClasses -> {
                        // ....
                        return fitClass.getAid());
                    }))
    .flatMap(id -> service.unbookClass(id))
    .subscribeOn(Schedulers.io())
    .observeOn(AndroidSchedulers.mainThread())
    .subscribe(...);