我正在嘗試調用多個服務（使用 Java Reactor），一個服務的輸出將決定是否應該調用下一個服務。通過調用 validateSession API 驗證會話是否有效檢查會話是否有效并且是否有關聯的登錄名獲取登錄的詳細信息檢查登錄詳細信息中是否包含名字如果以上都通過，則生成憑據線.filter(details -> details != null && StringUtils.isNotBlank(details.getFName))給出錯誤，因為“細節”被解釋為單聲道。如果我更改代碼以使用 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);
2 回答
呼啦一陣風
TA貢獻1802條經驗 獲得超6個贊
你可以這樣簡化：
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方法的參數。
拉風的咖菲貓
TA貢獻1995條經驗 獲得超2個贊
下面的代碼解決了這個問題。
Map returns a <Mono<Mono>> while flatMap returns a <Mono>
Mono<Credentials> response = dao.validateSession(sessionId) .filter(session -> session != null && StringUtils.isNotBlank(session.getLogin())) .map(session -> dao.getDetails(session.getLogin())) .flatMap(session->session) .filter(details -> details != null && StringUtils.isNotBlank(details.getFName)) .map(details -> dao.generateCredentials()) .flatMap(credentials -> credentials);
添加回答
舉報
0/150
提交
取消