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

Question

我有一个Slick来源，可产生多个来源：

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

如何将createNewSource产生的源连接为一个大型源。

Answer 1

使用flatMapConcat或flatMapMerge：