kotlin - 如何从rxjava中的列表列表执行过滤器运算符

Question

下午好。
所以我得到了一个列表，里面是这样的列表:

    {
  "category" : [
    {
      "name": "Bathroom",
      "products": [
        {
          "name": "Sink01"
        },
        {
          "name": "Shower01"
        }
      ]
    },{
      "name": "Kitchen",
      "products": [
        {
          "name": "Table"
        },
        {
          "name": "Stove"
        }
      ]
    }
  ]
}

因此，例如，如果用户选择类别“浴室”，我想使用rxjava来过滤类别“浴室”中的产品列表，如果他们选择类别“厨房”，我想从类别“中获取产品列表”厨房”。

到目前为止，这是我尝试过的:

    fun getProducts(category: Category): Single<MutableList<Product>> {
         return service.getProductsByCategories().filter{ response ->
             response.categoriesList.forEach {
                if (it.name == category.name) {
                  category.products
                }
             }
         }
    }

现在，我收到“类型不匹配。要求: Single<MutableList<Product>>，找到: Maybe<MyResponse!>!”

为什么会这样呢？
正确的过滤方法是什么？

提前致谢。

问候

Answer 1

您可以展开getProductsByCategories响应，筛选正确的类别，在产品列表中进行映射，然后将其转换为所需的输出类型:

getProductsByCategories()
.flattenAsObservable { it }
.filter { it.name == category.name }
.map { it.products }
.single( ArrayList<Product>() )