Rx-Java を使用して、配列内の各項目に対して API 呼び出しを実行しています。すべての操作が完了したら OnComplete アクションを呼び出したいのですが、呼び出されていません。配列項目に対する操作は正常に完了します。
public Observable<User> report(Long[] userIds) {
return Observable.from(userIds).flatMap(new Func1<Long, Observable<User>>() {
@Override
public Observable<User> call(Long id) {
return reportSpam(id);
}
});
}
public Observable<User> report(final Long id) {
return Observable.create(new Observable.OnSubscribe<User>() {
@Override
public void call(Subscriber<? super User> subscriber) {
try {
twitter.report(id);
} catch (TwitterException e) {
subscriber.onError(e);
}
}
});
}
final Long[] usersIds = selectedToUsersIds();
report(usersIds).subscribeOn(Schedulers.newThread())
.observeOn(AndroidSchedulers.mainThread()).subscribe(new Action1<User>() {
@Override
public void call(User user) {
//nothing to do here, don't even need the User
}
}, new Action1<Throwable>() {
@Override
public void call(Throwable throwable) {
//handle this
}
}, new Action0() {
@Override
public void call() {
Toast.makeText(getActivity(), getString(R.string.reported_for_spam, usersIds.length), Toast.LENGTH_SHORT).show();
}
});