时间戳

首页 > 解决方案 > api调用之前的RxJava转换请求类型

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

问题描述

我有一个用户列表（想象 POJO 用户的 ID 为 int，名称为字符串），我想进行 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 调用本身中转换这个列表，在链内部使用一个运算符，就像我们使用它来转换、映射、过滤等等结果列表一样。

有办法吗？谢谢

标签： androidjava-streamrx-javarx-android

解决方案

那这个呢？

您可以Observable#fromIterable按顺序使用从User到Integer(id) 的转换。这是通过应用来完成的toList。这只能在有限流上完成，因为当Observable从不发送onComplete. 在您的情况下，这是可能的，因为 aList始终是有限的。

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;
    }
  }
}

推荐阅读