Akka Stream Java - возможно ли объединить неизвестное количество источников в один

Question

У меня есть источник Slick, который создает несколько источников:

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

Как объединить источники, созданные createNewSource, в один большой источник.

Answer 1

Используйте flatMapConcat или flatMapMerge:

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