从WebClient流到Flux。阻止超时引发异常

Question

        WebClient client = WebClient.builder().baseUrl(URL).build();

        List<Item> items = client
                .get()
                .retrieve()
                .bodyToFlux(Item.class)
                .limitRequest(10)
                .collectList()
                .block(Duration.ofSeconds(10));

java.lang.IllegalStateException: Timeout on blocking read for 10000 MILLISECONDS

如何使用WebClient读取长达x秒的流，然后返回检索到的项？

Answer 1

我想检索元素，直到我收到10个元素，或者10秒钟过去。

听起来buffertimeout()正是您想要的。

将传入的值收集到多个列表缓冲区中，每次缓冲区达到最大大小或超过maxTime持续时间时，返回的流量都会发出这些值。

List<Item> items = client
        .get()
        .retrieve()
        .bodyToFlux(Item.class)
        .bufferTimeout(10, Duration.ofSeconds(10)) //first parameter is max number of elements, second is timeout
        .blockFirst();