如何将元素添加到流中

Question

我有一个流程，其中连接了两个S3Sink。在第一个s3Sink中，我希望文件没有标题，而在第二个s3Sink（s3SinkHeaders）中，我希望文件具有标题。

            val header = "one,two,three"
            Flow[MyRegister]
              .map(mrar => mrar.toCSV + "\n")
              .map(ByteString(_))
              .alsoToMat(sinkWithHeader)(Keep.right)
              .toMat(sinkWithoutHeader)(Keep.both)

之后如何仅对header而不对sinkWithHeader附加sinkWithoutHeader？

Answer 1

为什么在Flow.prepend中找不到documentation？

import akka.stream.scaladsl._

def foo[I, O, M](flow: Flow[I, O, M], head: O): Flow[I, O, M] =
  flow.prepend(Source single head)