如何从Source [ByteString,Any] akka流中实现2个参数

这样我就可以从Source [ByteString,Any]中实现inputStream和Feature [ByteString]

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

如何通过一项操作获取它?

xsj21 回答:如何从Source [ByteString,Any] akka流中实现2个参数

这是您要寻找的吗?

val bs: (Future[ByteString],InputStream) = Source.empty[ByteString]
    .alsoToMat(Sink.head)(Keep.right)
    .toMat(StreamConverters.asInputStream())(Keep.both)
    .run()
本文链接:https://www.f2er.com/3145438.html

大家都在问