APIに順番に渡すべきオブジェクトのリストがあり、すべての呼び出しが完了したら最終的なコールバックが必要です。コード構造は次のようになりますRxJavaとAndroidを使用した複数のAPI呼び出し
//Singleton class
public class RestAPIManager {
public Completable doSomething(A a) {
//Make API call here and return Completeable
}
}
//Class from which the above API call is made
public class FragmentA extends Fragment {
List<A> aList = new ArrayList<A>;
//This method should return completable after all calls are made
private Completable callDoSomething(List<A> data) {
// The code that I tried
Observable.just(data)
.flatMap(new <List<A>, Observable<?>>() {
@Override
public Observable<?> call(List<A> dataList) {
//WHAT SHOULD BE RETURNED FROM HERE
for (A a : dataList) {
RestAPIManager.getInstance().doSomething(a)
}
}
})
.doOnCompleted(new Action0() {
@Override
public void call() {
}
})
.doOnError(new Action1<Throwable>() {
@Override
public void call(Throwable throwable) {
}
})
.toCompletable();
}
}
私はRxJavaを使い始めました。これで先に進む方法がわかりません。