假设我有val fs2Stream: Stream[IO, Byte]
并且我需要,例如,调用一些需要java.io.InputStream
.
我想我对 FS2 太陌生了,但我似乎找不到答案。我试过使用fs2.io.toInputStream
,fs2.io.readInputStream
但我不知道如何提供一些必需的参数。我已经在全能的谷歌上搜索了答案,但自从大多数人最后一次寻找答案以来,API 似乎已经发生了变化。
我该如何做以下事情?
def myFunc(data: fs2.Stream[IO, Byte]): InputStream[Byte] = someMagicalFunction(data)