api 调用之前的 RxJava 转换请求类型

Question

我有一个用户列表（假设 POJO 用户的 Id 为 int，Name 为字符串），我想进行一个 API 调用，将 ID 列表而不是用户列表作为参数传递。所以，正如我所拥有的那样：

    List<Integer> usersIDs = new ArrayList<>();
    usersList.stream().forEach(user -> users.add(users.getId()));

    Single.fromCallable(() -> api.downloadData())
            .observeOn(AndroidSchedulers.mainThread())
            .subscribeOn(Schedulers.io())
            .subscribe();

但我想在 RxJava 调用本身中转换此列表，在链内使用运算符，就像我们使用它来转换、映射、过滤等结果列表一样。

有办法吗？谢谢

Answer 1

这个呢？

您可以使用 Observable#fromIterable 将 User 转换为 Integer (id)。这是通过应用 toList 完成的。这只能在有限流上完成，因为当 Observable 永远不会发送 onComplete 时，你永远不会得到发射。在你的情况下这是可能的，因为 List 总是有限的。

class So65424108 {
  @Test
  void so65424108() {
    List<User> users = Arrays.asList(new User(1, "Hans"), new User(2, "Wurst"));

    Api api = new ApiImplStub();
    TestScheduler testScheduler = new TestScheduler();

    ReactiveApi reactiveApi = new ReactiveApi(api, testScheduler);

    TestObserver<Boolean> test = Observable.fromIterable(users)
        .map(user -> user.userId)
        .toList()
        .flatMap(reactiveApi::downloadData)
        .observeOn(testScheduler)
        .test();

    testScheduler.triggerActions();

    test.assertComplete().assertValue(false);
  }

  interface Api {
    Boolean downloadData(List<Integer> ids);
  }

  static final class ApiImplStub implements Api {
    @Override
    public Boolean downloadData(List<Integer> ids) {
      return false;
    }
  }

  static final class ReactiveApi {
    private final  Api api;
    private final Scheduler scheduler;

    ReactiveApi(Api api, Scheduler scheduler) {
      this.api = api;
      this.scheduler = scheduler;
    }

    public Single<Boolean> downloadData(List<Integer> ids) {
      return Single.fromCallable(() -> api.downloadData(ids))
          .subscribeOn(scheduler);
    }
  }

  static final class User {
    final int userId;
    final String name;

    User(int userId, String name) {
      this.userId = userId;
      this.name = name;
    }
  }
}

api 调用之前的 RxJava 转换请求类型

RxJava transform request type before api call

android

rx-java

java-stream

rx-android