Как материализовать 2 параметра из потоков akka Source [ByteString, Any] - PullRequest
0 голосов
/ 07 ноября 2019

Так что я могу материализовать inputStream и Feature [ByteString] из Source [ByteString, Any]

val bs = fileStream.runWith(Sink.head)
val is = fileStream.runWith(StreamConverters.asInputStream())

Как я могу получить его, используя одну операцию?

1 Ответ

2 голосов
/ 07 ноября 2019

Это то, что вы ищете?

val bs: (Future[ByteString], InputStream) = Source.empty[ByteString]
    .alsoToMat(Sink.head)(Keep.right)
    .toMat(StreamConverters.asInputStream())(Keep.both)
    .run()
...