akka.Source中第二个类型参数的用途和含义是什么

Question

第二类参数的用途和含义是akka.Source什么？

示例代码: -

  def stream: ServiceCall[Source[String, NotUsed], Source[String, NotUsed]]

根据我迄今为止看到的代码,默认情况下第二个类型参数设置为akka.NotUsed.但我不知道它有什么意义.

Answer 1

第二个参数是具体化的值,也就是说,当您运行源时,它是run方法返回给您的值.Akka流中的所有流形状都有它们,即源,汇,流,双流等.有了水槽,很明显,如果你要折叠流,你最终会得到一个单一的值,那个值通过物化值给出,这是结果的未来:

def fold[U, T](zero: U)(f: (U, T) ? U): Sink[T, Future[U]]

但是对于消息来源来说,它不太明显,但这里有一个例子:

def actorRef[T](bufferSize: Int, overflowStrategy: OverflowStrategy): Source[T, ActorRef]

这是一个Source,当你运行它,实现一个ActorRef.您发送给actor的每条消息都将从源发出.如果你想在Lagom中使用它,你会做这样的事情:

def stream = ServiceCall { _ =>
  Source.actorRef[String](16, OverflowStrategy.dropHead)
    .mapMaterializedValue { actor =>
      // send messages here, or maybe pass the actor to somewhere else
      actor ! "Hello world"
      // And return NotUsed so that it now materializes to `NotUsed`, as required by Lagom
      NotUsed
    }
}