小编Bas*_*uis的帖子

使用弹簧5,使用反应器,我们有以下需要.

Mono<TheResponseObject> getItemById(String id){
    return webClient.uri('/foo').retrieve().bodyToMono(TheResponseObject)
}

Mono<List<String>> getItemIds(){
    return webClient.uri('/ids').retrieve().bodyToMono(List)
}

Mono<RichResonseObject> getRichResponse(){
    Mono<List> listOfIds = Mono.getItemIds()
    listOfIds.each({ String id ->
        ? << getItemById(id) //<<< how do we convert a list of ids in a Mono to a Flux
    })
    Mono<Object> someOtherMono = getOtherMono()
    return Mono.zip((? as Flux).collectAsList(), someOtherMono).map({
        Tuple2<List, Object> pair ->
        return new RichResonseObject(pair.getT1(), pair.getT2())
    }).cast(RichResonseObject)
}

有什么方法可以将Mono <List <String >>转换为Flux <String>？

    Tue Apr  1 17:21:38.898 [initandlisten] connection accepted from 127.0.0.1:58349 #42 (5 connections now open)
Tue Apr  1 17:21:50.855 [journal] exception in dur::groupCommitLL causing immediate shutdown: boost::filesystem::current_path: Too many open files in system
Tue Apr  1 17:21:50.855 dur4
Tue Apr  1 17:21:50.855 Got signal: 6 (Abort trap: 6).

Tue Apr  1 17:21:50.858 Backtrace:
0x100447d8b 0x100001531 0x7fff9225990a 0x104e80818 0x7fff922b0f61 0x1001e462a 0x10016dc3c 0x10016d537 0x10047a8b5 0x7fff9226b772 0x7fff922581a1 
 0   mongod                              0x0000000100447d8b _ZN5mongo15printStackTraceERSo + 43
 1   mongod                              0x0000000100001531 _ZN5mongo10abruptQuitEi + 225
 2   libsystem_c.dylib                   0x00007fff9225990a _sigtramp + …