相关疑难解决方法(0)

我有一个 Web 服务，我正在尝试使用新的 Spring 5 WebClient 来使用它。

工作示例

# GET /orders/\n[\n    { orderId: 1, ...\xc2\xa0},\n    { orderId: 1, ...\xc2\xa0}\n]\n

以及调用的java代码

// Java\nFlux<Order> ordersStream = webClient.get()\n    .uri("/orders/")\n    .exchange()\n    .flatMap(response -> response.bodyToFlux(Order.class));\n

问题

来自 Web 服务的响应是分页的，因此不直接包含项目列表，如上例所示。

看起来像这样

# GET /orders/\n{\n    "error": null,\n    "metadata": {\n      "total": 998,\n      "limit": 1000,\n      "offset": 0\n    },\n    "data": [\n       { orderId: 1, ... },\n       { orderId: 2, ... },\n    ]\n}\n

我怎样才能获得子"data"密钥Flux<Order>？

可能的解决方案，但我不知道这是否是最好的方法......

创建一个包装类并转换包装器 …

目前已经是一个关于分页的问题有ReactiveCrudRepository。接受的解决方案适用于遵循某种findBy格式的查询。项目文档还引用了该用法：

https://docs.spring.io/spring-data/mongodb/docs/current/reference/html/#mongo.reactive.repositories.usage

示例 158. 用于持久化 Person 实体的基本存储库接口

public interface ReactivePersonRepository extends
ReactiveSortingRepository<Person, String> {

  Flux<Person> findByFirstname(String firstname);                     


  Flux<Person> findByFirstname(Publisher<String> firstname);          


  Flux<Person> findByFirstnameOrderByLastname(String firstname,
Pageable pageable); 

  Mono<Person> findByFirstnameAndLastname(String firstname, String
lastname);       

  Mono<Person> findFirstByLastname(String lastname);                  
}

Run Code Online (Sandbox Code Playgroud)

问题是这不适用于 findAll：

interface CustomerRepository : ReactiveCrudRepository<Customer, String> {
    fun findAll(pageable: Pageable): Flux<Customer>

例外：

Caused by: org.springframework.data.mapping.PropertyReferenceException: No property findAll found for type Customer!

Spring Data MongoDB 是否以某种方式支持这一点？