返回错误会更改方法签名

Question

我从教程中感觉到，返回一个可丢弃的，不应该改变方法返回类型。

以下是我的尝试：

1. 使用句柄时，一切都很好，直到我添加. timeout（），然后函数返回类型更改为Flux

private Flux<String> exampleHandle()
{
    MutableHttpRequest<String> req = HttpRequest.GET("http://localhost:8080");

    return httpClient.exchange(req, TokenResponse.class)
        .handle((response, sink) -> {
            Optional<TokenResponse> optionalBody = response.getBody();
            if (optionalBody.isEmpty()) {
                sink.error(new InitializationException("Failed to fetch authentication token. Body is null."));
            } else {
                TokenResponse tokenResponse = optionalBody.get();
                String accessToken = tokenResponse.getAccessToken();
                if (accessToken != null) {
                    sink.next(accessToken);
                } else {
                    sink.error(new InitializationException("Failed to fetch authentication token. Authentication token is null."));
                }
            }
        });
       // .timeout(Duration.ofSeconds(10)); // Timeout changes return type to Flux<Object>
}

private Flux<String> exampleMap()
{
    MutableHttpRequest<String> req = HttpRequest.GET("http://localhost:8080");

    return httpClient.exchange(req, TokenResponse.class)
        .map(response -> {
            Optional<TokenResponse> optionalBody = response.getBody();
            if (optionalBody.isEmpty()) {
                return Flux.error(new InitializationException("Failed to fetch authentication token. Body is null."));
            } else {
                TokenResponse tokenResponse = optionalBody.get();
                String accessToken = tokenResponse.getAccessToken();
                if (accessToken != null) {
                    return accessToken;
                } else {
                    return Flux.error(new InitializationException("Failed to fetch authentication token. Authentication token is null."));
                }
            }
        });
}

能不能找个更有知识的人解释一下我做错了什么？非常感谢。




Answer 1

您应该在句柄之前移动超时：

 return httpClient.exchange(req, TokenResponse.class)
        .timeout(Duration.ofSeconds(10))
        .handle((response, sink) -> {

至于map案例，看一下方法签名：

通量映射（函数

map使用函数

有用的链接：

• 使用Retor抛出异常的正确方法
• 地图vs反应器中的平面图