从单个＜list＞可观察对象获取列表

Question

我有一个方法返回＜code＞Single

private fun getListOfDownload(): ArrayList<HistoryItem> {
    val downloads = manager.lastHundredVisitedHistoryItems()
    downloads.subscribe { t ->
        return t; // not allowed
    }
}

我可以使用订阅，但这不允许我从中返回列表。

我还尝试了映射。

downloads.map { t: List<HistoryItem> -> return t } // again `return t` is not allowed.

编辑

我可以通过以下方式完成这项工作：

private fun getListOfDownload(): ArrayList<HistoryItem> {
        var list = ArrayList<HistoryItem>()
        val downloads = manager.lastHundredVisitedHistoryItems()
        downloads.subscribe { t ->
            list = t as ArrayList<HistoryItem>
        }
        return list
    }

请告诉

• 如果这种方式是正确的

我是反应式编程新手，请解释一下。

Answer 1

您可以使用subscribe获取列表，如下所示:

 @NonNull
public Single<String> getHistoryPage() {
    return Single.create(new SingleAction<String>() {
        @Override
        public void onSubscribe(@NonNull final SingleSubscriber<String> subscriber) {


            mHistoryModel.lastHundredVisitedHistoryItems()
                    .subscribe(new SingleOnSubscribe<List<HistoryItem>>() {
                        @Override
                        public void onItem(@Nullable List<HistoryItem> item) {
                      final StringBuilder historyBuilder = new StringBuilder(HEADING_1 + mTitle + HEADING_2);      

                            Iterator<HistoryItem> it = item.iterator();
                            HistoryItem helper;
                            while (it.hasNext()) {
                                helper = it.next();
                                historyBuilder.append(PART1);
                                historyBuilder.append(helper.getUrl());
                                historyBuilder.append(PART2);
                                historyBuilder.append(helper.getTitle());
                                historyBuilder.append(PART3);
                                String url = helper.getUrl();
                                try {
                                    URL url1 = new URL(url);
                                    authority = url1.getAuthority();
                                } catch (MalformedURLException e) {
                                    e.printStackTrace();
                                }
                                historyBuilder.append(authority);   //No need of path showing of History file.
                                historyBuilder.append(PART4);
                            }

                            historyBuilder.append(END);
                            File historyWebPage = getHistoryPageFile(mApp);
                            FileWriter historyWriter = null;
                            try {
                                //noinspection IOResourceOpenedButNotSafelyClosed
                                historyWriter = new FileWriter(historyWebPage, false);
                                historyWriter.write(historyBuilder.toString());
                            } catch (IOException e) {
                                Log.e(TAG, "Unable to write history page to disk", e);
                            } finally {
                                Utils.close(historyWriter);
                            }

                            subscriber.onItem(Constants.FILE + historyWebPage);
                            subscriber.onComplete();
                        }
                    });
        }
    });
}

通过使用上面的代码，你可以在html页面中获得历史列表。为此，您必须使用StringBuilder，然后才能获得完整的历史页面

Answer 2

我认为订阅lambda是交叉的，这意味着它不允许本地返回

您通常在这里要做的是在订阅{}中使用列表来实现其目的（更新回收器视图）

例如：

val compositeDisposable = CompositeDisposable()

private fun downloadList() {
    manager.lastHundredVisitedHistoryItems()
        downloads.subscribe { downloadedList ->
            this.list = downloadedList
            // or
            adapter.updateDataSet(downloadedList)
        }.addTo(compositeDisposeable)
    }
}

您还需要将您的一次性添加到CompositeDisposable以防止内存韭菜的可能性

Answer 3

在您的代码中，< code>getListOfDownload返回< code>ArrayList

这就是为什么您不能返回订阅块中的项目，因为该块是lamda，它将遵守ArrayList

但如果你不在乎观察结果你可以这样做，

private fun getListOfDownload(): ArrayList<HistoryItem> {
    val downloads = manager.lastHundredVisitedHistoryItems()
    return downloads.blockingGet()
}

但是当我们应用< code>blockingGet()时，您将失去对< code > lastpositedhistoryitems 的异步调用，但是由于您没有在单独的线程上观察到它，我假设您想在主线程上调用它。

但是如果您想观察< code > lastpositedhistoryitems()，那么您可以将该方法作为参数传递，该参数将充当< code>ArrayList的消费者

private fun getListOfDownload( listener : (ArrayList<LoginViewModel.HistoryItem>) -> Unit) {
        val downloads = manager.lastHundredVisitedHistoryItems()
        downloads.subscribe { t -> listener.invoke(t) }
}

// when you call above method look like below
// here variable `it` is nothing but a object of ArrayList<LoginViewModel.HistoryItem>
getListOfDownload { adapter.updateDataSet(it) }