java - 使用过滤器和 Map 链接 Java Reactor Mono

Question

我正在尝试调用多个服务(使用 Java Reactor)，一个服务的输出将决定是否应该调用下一个服务。

1. 通过调用 validateSession API 验证 session 是否有效
2. 检查 session 是否有效以及是否有关联的登录信息
3. 获取登录详细信息
4. 检查登录详细信息中是否包含名字
5. 如果以上全部通过，则生成凭据

线路

.filter(details -> details != null && StringUtils.isNotBlank(details.getFName))

给出错误，因为“details”被解释为 Mono。

如果我更改代码以使用 flatMap 而不是 Map，它可以正常工作，但我需要同步响应，因为我需要等待一切完成才能生成凭据。

.map(session -> dao.getDetails(session.getLogin()))
                .filter(details -> details != null && StringUtils.isNotBlank(details.getFName))

下面是有问题的代码。

Mono<Credentials> response = dao.validateSession(sessionId)
                .filter(session -> session != null && StringUtils.isNotBlank(session.getLogin()))
                .map(session -> dao.getDetails(session.getLogin()))
                .filter(details -> details != null && StringUtils.isNotBlank(details.getFName))
                .map(details -> dao.generateCredentials())
                .cast(Credentials.class);

Answer 1

你可以这样简化:

Mono<Credentials> response = dao.validateSession(sessionId)
                .filter(session -> StringUtils.isNotBlank(session.getLogin()))
                .flatMap(session -> dao.getDetails(session.getLogin()))
                .filter(details -> StringUtils.isNotBlank(details.getFName))
                .flatMap(details -> dao.generateCredentials());

我更改了用于简化的运算符，但我认为最后一步需要将 details 对象用作 generateCredentials 方法的参数。