嗨,我刚刚开始学习反应式编程
我这里有这段代码,我的过程应该是
我将调用tokenRepository来获取令牌,然后将token.getAccessToken()用作cardRepository.findAllCards()上的参数
public class CardService {
private final CardRepository cardRepository;
private final TokenRepository tokenRepository;
public CardService(CardRepositorycardRepository,
TokenRepository tokenRepository) {
this.cardRepository = cardRepository;
this.tokenRepository = tokenRepository;
}
public Mono<CardCollection> findAllCards(MultiValueMap<String, String> queryParams) {
Mono<Token> token =tokenRepository.requestToken();
// then I would like to use the token.getAccessToken
return cardRepository.findAllCards(token.getAccessToken, queryParams); // Then this should return Mono<CardCollection>
}
}
想知道这是否可能吗?
最佳答案
尽管我不确定这是否是正确的方法,但我找到了答案。
How to pass data down the reactive chain
这就是我对代码所做的。
public Mono<CardCollection> findAllCards(MultiValueMap<String, String> queryParams) {
return tokenRepository.requestToken().flatMap(token -> {
return cardRepository.findAllCards(token.getAccessToken(), queryParams);
});
}