Akka Streams - понимание того, когда и как работает материализация

Да, поток можно материализовать несколько раз. И да, если поток запускается несколько раз, он каждый раз материализуется. Из документация:

Поскольку поток может быть материализован несколько раз, материализованное значение также будет вычисляться заново для каждой такой материализации, что обычно приводит к возвращению разных значений каждый раз. В приведенном ниже примере мы создаем два запущенных материализованных экземпляра потока, которые мы описали в переменной runnable, и обе материализации дают нам другой Future из карты, хотя мы использовали тот же sink для ссылки на будущее:

// connect the Source to the Sink, obtaining a RunnableGraph
val sink = Sink.fold[Int, Int](0)(_ + _)

val runnable: RunnableGraph[Future[Int]] =
  Source(1 to 10).toMat(sink)(Keep.right)

// get the materialized value of the FoldSink
val sum1: Future[Int] = runnable.run()
val sum2: Future[Int] = runnable.run()

// sum1 and sum2 are different Futures!

Думайте о потоке как о многоразовом проекте, который можно запускать / материализовать несколько раз. Материализатор необходим для материализации потока, а Akka Streams предоставляет материализатор под названием ActorMaterializer. Материализатор выделяет необходимые ресурсы (акторов и т. Д.) И выполняет поток. Хотя обычно один и тот же материализатор используется для разных потоков и нескольких материализаций, каждая материализация потока запускает выделение ресурсов, необходимых для запуска потока. В приведенном выше примере sum1 и sum2 используют одну и ту же схему (runnable) и один и тот же материализатор, но они являются результатами различных материализаций, в результате которых были выделены разные ресурсы.