我正在嘗試調(diào)用多個服務(wù)（使用 Java Reactor），一個服務(wù)的輸出將決定是否應該調(diào)用下一個服務(wù)。通過調(diào)用 validateSession API 驗證會話是否有效檢查會話是否有效并且是否有關(guān)聯(lián)的登錄名獲取登錄的詳細信息檢查登錄詳細信息中是否包含名字如果以上都通過，則生成憑據(jù)線.filter(details -> details != null && StringUtils.isNotBlank(details.getFName))給出錯誤，因為“細節(jié)”被解釋為單聲道。如果我更改代碼以使用 flatMap 而不是 Map，它可以正常工作，但我想要一個同步響應，因為我需要等待一切完成才能生成憑據(jù)。.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條經(jīng)驗 獲得超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());
我已經(jīng)更改了用于簡化的運算符，但我認為最后一步需要將details對象用作generateCredentials方法的參數(shù)。
拉風的咖菲貓
TA貢獻1995條經(jīng)驗 獲得超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
提交
取消