主页 / 问题 / 860911
Accepted
Антон Лялин
Asked:2020-07-27 14:30:16 +0000 UTC2020-07-27 14:30:16 +0000 UTC

如何将数据从 Observable<io.rxjava> 保存到 List<>？

  • 772

有一种从 json 接收数据并创建的方法Observable<>，我需要从中获取数据并将其保存到List<>：

@NonNull
public Observable<List<BaseProducts>> getProducts(){
    return bankApi.getProductsObservable()
            //здесь получаю result
            .map(productResponseApiResponse -> productResponseApiResponse.getResult())
            //здесь конвертирую result в готовые типы (DTO)
            .map(response -> converter.convert(response))
            .subscribeOn(Schedulers.io())
            .observeOn(AndroidSchedulers.mainThread());
}

接下来，我需要过滤数据并将其传递给 List<>

@NonNull
private Observable<List<BaseProducts>> getActive(){
    return getProducts()
            .flatMap(Observable::fromIterable)
            .filter(products -> !products.getStatus().equals(ACTIVE_PRODUCTS))
            .toList()
            .toObservable();
}

有一个过滤，我现在如何将过滤后的流保存在 List<> 中？

例如，如果您保存到List<>

@NonNull
public List<BaseProducts> getActiveProducts(){
    List<BaseProducts> activeProducts = new ArrayList<>();
    getProducts()
            .subscribe(products -> activeProducts.addAll(products));
    return activeProducts;
}

但是通过debugger显示activeProducts = null当它products存储数据时

@Inject
public ProductsItemBuilderImpl(@NonNull ProductsRepository repository) {
    this.baseProducts = repository.getActiveProducts();
}

@NonNull
@Override
public List<BaseProductsItem> build() {
    buildDeposits(baseProducts);
    buildCredits(baseProducts);
    buildDebitCards(baseProducts);
    buildCreditCards(baseProducts);
    return baseProductsItems;
}

在这里，我将其称为 List

java

1 个回答

  1. Best Answer

    错误就在这里：

    List<BaseProducts> activeProducts = new ArrayList<>();
getProducts()
    .subscribe(products -> activeProducts.addAll(products));
return activeProducts;

    您不能只接受它并从订阅中同步返回值。事实上，你根本不应该这样做。RxJava创建以实现反应式异步方法。

    更简单地说，在执行该行时，return activeProducts列表仍然是空的，因为到它的转换将在前一行之后立即发生，而无需等待您传递的 lambdas 的执行。

    我看不出详细描述所有内容的意义——互联网上有一半是关于异步编程的（甚至在Javaand中RxJava），请查找有关此主题的文章。我指出了你的错误，请注意。您已经熟悉了操作符RxJava并开始使用它，但不知道如何使用它。

    不要尝试存储从您的字段中某处收到的数据，使用方法链。接收到的数据 - 称为可以处理它的方法，将这些数据传递到那里。他们将它们放在适配器列表中的某个位置，在 UI 上显示它们，将它们保存到数据库中，等等。重新考虑方法——不要将数据存储在字段中，然后从某个地方调用它，并在收到时立即调用接收者（侦听器、订阅者），它可以处理这些数据。

    • 2

相关问题