Akka Stream Java-是否可以将未知数量的源合并为一个

2020年2月28日 17点热度 0条评论

我有一个Slick源,它产生多个源:

 Source myBigSource = Slick.source(slickSession, sqlQueryString,
     (SlickRow row) -> {
          return (Source)createNewSource(row, someContext);
     }
 );

如何将createNewSource产生的源连接到一个大源中。

解决方案如下:

使用flatMapConcat或flatMapMerge:

Source myBigSource = Slick.source(slickSession, sqlQueryString,
    (SlickRow row) -> {
        return (Source)createNewSource(row, someContext);
    }
).flatMapConcat((o) -> o);