Заставьте Akka Stream объединить сцены

Question

Способ слияния элементов akka-stream не очень прозрачен.Мне было интересно, если есть способ:

• Чтобы увидеть, какие этапы слиты вместе
• Чтобы объединить некоторые этапы

Answer 1

Чтобы увидеть, какие этапы слиты воедино

Я не знаю ни одного документированного метода выявления этапов слитых графов.Довольно безопасно предположить, что встроенные линейные операторы будут по умолчанию объединены (если не применяется async).

Чтобы объединить некоторые этапы

В более ранней версии Akka Stream предусмотрены некоторые методы для ручного этапа слияния , и вы можете отключить автоматическое слияние по умолчанию со следующим параметром конфигурации:

akka.stream.materializer.auto-fusing=off

Но с последним API (2.5) пытается не только обрабатывать автоматическое плавление под колпаком, но также запрещает ручное плавление .

Answer 2

Я бы сказал, что документация довольно прозрачна в отношении объединения операторов:

По умолчанию Akka Streams объединит операторы потока.

Слияние операторов - это поведение по умолчанию, означающее, что по умолчанию весь ваш поток будет выполняться в одном и том же действующем субъекте.Чтобы изменить это поведение, используйте метод async для определения асинхронных границ на этапах, которые вы не хотите объединять.