异步方法后的平面图？

Question

我有一个要求以异步方式调用 xxx 方法并且 return 立即成功响应。但是，我的 xxx() 方法在 flatMap() 之后没有执行任何操作。

public Observable<ReturnDataType> performOperations(List PhoneList){
  xxx(PhoneList);
  return Observable.just(return successObservable);
}

private void xxx(List PhoneList){
Observable.from(phoneList).flatMap(phone -> {
 doSomeOperations
}).toList();
}

问题：如果以异步方式调用任何方法，那么它的行为是否像这样？我错过了什么吗？

谢谢。

Answer 1

代码修改如下：

    Observable.from(phoneList)
            .flatMap(phone -> {
                doSomeOperations;
            })
            .toList()
            .toBlocking()
            .first();

还有一件事，代码似乎更适合使用 Completable 而不是 Observable。

    Observable.from(phoneList)
            .flatMap(phone -> {
                doSomeOperations;
            })
            .toCompletable()
            .await();

异步方法后的平面图？

flatmap after async method?

asynchronous

observable

rx-java

flatmap