如何创建流程？

Question

我刚刚开始学习akka流并想创建一个流程。我会说，当我尝试使用它时，我确实理解流的概念但是失败了。

从我的例子来看：

  final class Foo(value: String)

  def chain2: Flow[String, Foo, Future[Foo]] =
    Flow.  

我不知道，如何完成它。入口是String，出口是Foo。

怎么编码呢？

Answer 1

不是这个

def chain2: Flow[String, Foo, NotUsed] = Flow.fromFunction[String, Foo](new Foo(_))

?

如果您需要修改materilaized值，您可以使用mapMaterializedValue

chain2.mapMaterializedValue(_ => Future(new Foo("abc"))): Flow[String, Foo, Future[Foo]]

https://doc.akka.io/docs/akka/2.5.22/stream/stream-flows-and-basics.html