scala – Source的类型参数是什么意思？

你是对的,这是Source发出的元素的类型.

垫

它是Source的物化形式.请注意,每个阶段(Flows,Sinks等)也将实现一个值.
这基本上是舞台本身运行后的副产品.

您可以将其描绘为在舞台运行时与舞台交互的手段.查看Akka提供的现成资源的例子是获得它的要点的好方法.

> Source.single将实现NotUsed.你没有意义与源相互作用,因为它只会产生一个元素,然后完成.
> Source.queue将实现SourceQueue.这是一个更有趣的案例,因为您可以通过向源提供消息来与源进行交互.您提供的消息将由源发出.
> Source.maybe将实现承诺.您可以使用Promise来控制源并使其发出一个元素,或者None.

当您连接不同的阶段时,请注意每个阶段都可能具有有用的物化价值.您可以使用viaMat / toMat和Keep DSL来选择要保留的内容.
在组合图上调用run()时,将返回一个或多个实现值.

查看下面示例中的类型是获取API要点的最佳方法：

val source: Source[Int,MatSrc]
  val sink: Sink[Int,MatSnk]

  val matSrc: MatSrc = source.toMat(sink)(Keep.left).run()
  val matSnk: MatSnk = source.toMat(sink)(Keep.right).run()
  val (m1: MatSrc,m2: MatSnk) = source.toMat(sink)(Keep.both).run()
  val n: NotUsed = source.toMat(sink)(Keep.none).run()

请注意,在许多示例中您可以找到的更简洁的DSL实际上是上述的快捷方式,其中仅保留最后一级(例如,接收器)的具体化值.

val mat3: Mat3 = source.viaMat(flow)(Keep.right).toMat(sink)(Keep.right).run()

是相同的

val mat3: Mat3 = source.via(flow).runWith(sink)

请参阅下面的文档以进一步阅读.

http://doc.akka.io/docs/akka/2.4/java/stream/stream-quickstart.html#Materialized_values