物化值如何在Akka Stream中工作

Question

我了解到，当我运行Akka流图时，它将实现最正确的组件。

但是要这样做：

Source.range(1,100).to(Sink.reduce((a,b) -> a+b)).run(materializer);

尽管最左边的部分是返回整数的接收器，但将实现NotUsed。>>

但是，对runWith进行同样的操作很正常：

Source.range(1, 100).runWith(Sink.reduce((a, b) -> a + b), materializer)
                .thenAccept(value -> LOGGER.info("The final value is {}", value));
我对run方法不太了解是什么？

我了解到，当我运行Akka流图时，它将实现最正确的组件。但是这样做：Source.range（1,100）.to（Sink.reduce（（a，b）-> a + b））。run（materializer）;将...

Answer 1