这样我就可以从Source [ByteString,Any]中实现inputStream和Feature [ByteString]
val bs = fileStream.runWith(Sink.head)
val is = fileStream.runWith(StreamConverters.asInputStream())
如何通过一项操作获取它?
这样我就可以从Source [ByteString,Any]中实现inputStream和Feature [ByteString]
val bs = fileStream.runWith(Sink.head)
val is = fileStream.runWith(StreamConverters.asInputStream())
如何通过一项操作获取它?
这是您要寻找的吗?
val bs: (Future[ByteString],InputStream) = Source.empty[ByteString]
.alsoToMat(Sink.head)(Keep.right)
.toMat(StreamConverters.asInputStream())(Keep.both)
.run()