获取前 10 项 RxJava

Question

我正在使用 RxJava 从 JSONplaceholder api 获取帖子列表。

https://jsonplaceholder.typicode.com/posts

我只想从列表中取出前 10 名并保存在数据库中。

我知道我需要使用 take 运算符，但不知道如何将它与 concatMap 一起使用。

这是我已经拥有的。

private fun loadPosts(){
        subscription = Observable.fromCallable { postDao.all }
                .concatMap { dbPostList ->
                    postApi.getPosts().concatMap { apiPostList -> 
//HERE i ONLY WANT TO TAKE 10 ITEMS AND SAVE IT (HOW CAN I USE TAKE OPERATOR HERE)
                        postDao.insertAll(*apiPostList.toTypedArray())
                        Observable.just(apiPostList)
                    }
                }
                .subscribeOn(Schedulers.io())
                .observeOn(AndroidSchedulers.mainThread())
                .doOnSubscribe { onRetrievePostListStart() }
                .doOnTerminate { onRetrievePostListFinish() }
                .subscribe(
                        { result -> onRetrievePostListSuccess(result) },
                        { onRetrievePostListError() }
                )
}

我尝试了以下代码，但它没有按预期工作。

postApi.getPosts()
        .take(10) // DOES NOT WORK
        .concatMap { apiPostList -> 
            postDao.insertAll(*apiPostList.toTypedArray())
            Observable.just(apiPostList)
        }

Answer 1

getPosts() 返回一个列表。要在您的情况下使用take(10)，您必须发出列表中的每个元素。但是，由于您一次性发出整个列表，就好像take(10) 正在尝试获取 10 个帖子列表而不是 10 个帖子。

我可以想出两种方法来解决这个问题。您可以将列表转换为可观察的，例如：

postApi.getPosts()
      .flatMap { Observable.fromIterable(it) }
      .take(10)
      .toList()

发出列表中的每一项，取出其中的 10 个，然后将结果收集到一个列表中，为您的concatMap 准备好。

另一种选择是手动对列表进行切片：

postApi.getPosts()
      .map { it.slice(0 until 10) }

不是那么 rx-ish 但仍然可以工作。

小心，因为这两种方法都假设列表中至少有 10 个项目。