预置流-对Sink的操作

Question

我有一个源头，我需要转化成另一个。一路走来，我也想进入溪流，并把它送到一个水槽。这对alsoTo和wireTap来说很好。

但是，我希望在数据到达接收器之前对其进行额外的转换：

Source ---> map ---> scan ---> map ---> return as Source
                           \
                            \ alsoTo
                             \
                              \ ---> map --> Sink

在医生里，我读到：

可以将流附加到源上，从而产生复合源，还可以将流添加到sink以获得新的接收器。

但是，我找不到一个例子来预置这样的流到Sink，例如在转发到Sink之前执行一个"map“操作。

非常简单的例子：

val sink = Sink.foreach(println)
val source = Source(List(1, 2, 3, 4, 5))
val transformed_source = source.map(n => n * 10).alsoTo(sink).map(n => n + 1)

// but I want something along the lines of
alsoTo(map(n => "The result is " + n) ~> sink)

Answer 1

我想Flow.to是我要找的。

def to[Mat2](sink: Graph[SinkShape[Out], Mat2]): Sink[In, Mat]

将此流连接到Sink，连接两者的处理步骤。