代码之家 › 专栏 › 技术社区 › Gonen I

在为所有对象阻塞之后从列表中的Monos获取对象的值

reactive-streams reactor spring-webflux spring java

Gonen I · 技术社区 · 6 年前

我正在关注Rossen Stoyanchev在Spring上的演示

https://www.youtube.com/watch?v=IZ2SoXUiS7M&t=935s

,并调用三个延迟的API,然后阻塞,直到它们全部完成。

List<Mono<Person>> personMonos = Stream.of(1, 2, 3)
        .map(i -> client.get().uri("/person/{id}", i).retrieve().bodyToMono(Person.class))
        .collect(Collectors.toList());

// Declare that we want to block until all monos in the list are done
Mono.when(personMonos).block();

下一步,在阻塞完成这三个调用之后,我可以得到三个返回的Person对象的值吗?如果是,怎么做?

0 回复 | 直到 6 年前

Chr3is 6 年前

单声道列表是一个助焊剂,助焊剂可以这样使用:

@Test
public void test() {

    Flux<Person> persons = Flux.just(1, 2, 3)
            .map(this::doRequest);

    List<Person> personList = persons.collectList().block();
}


@RequiredArgsConstructor
@Getter
static class Person {
    private final int id;
}

private Person doRequest(int id) {
    return new Person(id);
}

您可以在此处找到更多信息: https://projectreactor.io/docs/core/snapshot/reference/#core-features

Bartosz Kiebdaj 6 年前

Mono.zip(Mono.just(1), Mono.just(2), Mono.just(3)).block();

推荐文章

PatPanda · 使用springboot验证请求中的列表是否为[null]

10 月前

Bojidar Kaloyanov · 为什么即使有有效的JWT,Spring Boot也会对安全端点的POST请求返回403 Forbidden?

10 月前

mikeb · Maven和Spring引导-我需要强制logback 1.5.13,但不能

10 月前

Nuñito Calzada · AWS SDK 1.12.780 Java版的凭据

11 月前

Python_user · build/lib不是由gradle build生成的

11 月前

Chirag Arora · 如何在构造函数中使用注入的依赖关系?

11 月前

sree · Spring Mongo仓库:通过传递id列表来获取对象列表

11 月前

David · 如何修复javax/xml/bind/DatatypeConverter的java.lang.NoClassDefFoundError错误

1 年前

RobertC · Spring中默认实现的Autowire接口

1 年前

molLbach · 向Spring后端发送axios post请求时出现400错误

1 年前