这是相关的代码:
Mono<ResponseEntity<String>> res = remoteCall(HttpMethod.POST, issueTokenUrl, GsonConvertor.getInstance().serialize(request));
Mono<IssueToken> it = res.map(this::getIssueToken);
远程调用成功(状态代码 200,具有很好的响应正文(,但流不会进入getIssueToken()
方法。方法如下:
private IssueToken getIssueToken(ResponseEntity<String> response) {
System.out.println("Inside the method"); //this line won't print on the console
HttpStatus statusCode = response.getStatusCode();
checkErrors(response);
return GsonConvertor.getInstance().deserialize(response.getBody(), IssueToken.class);
}
有人可以告诉我为什么会这样吗?
>map(Function)
只是创建一个新Mono
但诀窍是不直接计算函数。当您使用它时,例如通过调用subscribe()
来评估它。