如何 return 单<ServerResponse>

Question

请在下面代码的评论部分查看我的问题 -

// This should return a list of all ids and their name and status info, e.g. as json
public Mono<ServerResponse> f1(String originalId) {

    // this gives list of ids which are comma separated       
    Mono<String> ids = f2(originalId);
    ids.flatMapIterable(line -> Arrays.asList(line.split(COMMA)))
            .doOnNext(id -> {
                Mono<String> idName = f3(id);
                Mono<String> idStatus = f4(id);

                Mono<Tuple2<String, String>> combined = Mono.zip(idName, idStatus);

                // How do i return all the combined Mono tuples as Mono<ServerResponse>
            }).subscribe();

    // Need to return proper Mono - not empty         
    return Mono.empty();
}

我也不确定我是否应该 return Flux 或 Mono 作为 return 类型的 f1() 作为其 id 列表及其各自的值

Answer 1

您需要 return Mono<ServerResponse>.

public Mono<ServerResponse> f1(String key) {
    Mono<String> ids = f2(key);
    Flux<IdInfo> idInfoFlux = ids.flatMapIterable(line -> Arrays.asList(line.split(",")))
            .flatMap(id -> {
                Mono<String> idName = getIdName(id);
                Mono<String> idStatus = getIdStatus(id);
                return Mono.zip(idName, idStatus, (name, status) -> new IdInfo(name, status));
            })
            .doOnNext(id -> System.out.println(id));
    return ServerResponse.ok().contentType(MediaType.APPLICATION_JSON).body(idInfoFlux, IdInfo.class);
}

// your DTO class that you would like to pass in response as json
public static class IdInfo {
    String idName;
    String idStatus;

    public IdInfo(String idName, String idStatus) {
        this.idName = idName;
        this.idStatus = idStatus;
    }

    public String toString() {
        return String.format("IdInfo [idName=%s, idStatus=%s]", idName, idStatus);
    }
}

如何 return 单<ServerResponse>

How to return Mono<ServerResponse>

reactor

spring-boot

spring-webflux