RXJava - concat 不起作用

Question

我在使用 RXJava 和 Kotlin 时遇到问题。

我正在使用 LiveData 和 Rx，我的问题是 concat 方法没有连接我在虚拟数据中的两个数组。

这是我的代码：

 disposables.
                add(
                Observable.concat(Observable.just(DummyContent.COMPANIES),
                        Observable.just(DummyContent.COMPANIES))
                .subscribeOn(Schedulers.io())
                .observeOn(AndroidSchedulers.mainThread())
                .subscribe({
                    Timber.d("get companies success ${it.size}" )
                    companiesLiveData.value = it
                },{
                     t -> Timber.e(t, "get companies error")
                }))

虚拟内容：

 val COMPANIES: MutableList<Company> = ArrayList()
  ...
   // Add some sample items.
        for (i in 1..4) {
            addCompany(createDummyCompany(i))
        }

当我运行代码时，我只在列表中看到 4 个元素，我期望收到 4 + 4 = 8 个项目，因为concat方法。

在 LogCat 中，我两次看到这条消息：让公司成功 4

我怎样才能做到这一点？

Answer 1

Observable.concat()连接

提供给它的两个流。因此，您将收到两个包含单个列表的事件。如果要合并列表本身，则必须发出单个元素而不是列表，并使元素再次成为列表。

Observable.concat(Observable.fromIterable(DummyContent.COMPANIES),
                  Observable.fromIterable(DummyContent.COMPANIES))
          .toList()