如何解决来自队列的 fs2 流不消耗元素
我想从队列创建流,将所有元素打印到控制台。 当前的一个片段不打印任何内容:
object TestApp extends App {
implicit val contextShift: ContextShift[IO] = IO.contextShift(ExecutionContext.global)
private val value: IO[(fs2.Stream[IO,Unit],String => IO[Unit],() => IO[Unit])] = for {
queue <- Queue.noneTerminated[IO,String]
} yield {
val stream: fs2.Stream[IO,Unit] = queue.dequeue.map(println)
def send(msg: String): IO[Unit] = queue.enqueue1(Some(msg))
def close(): IO[Unit] = queue.enqueue1(None)
(stream,send _,close _)
}
val (stream,send,close) = value.unsafeRunSync()
send("msg1").unsafeRunSync()
send("msg2").unsafeRunSync()
}
流创建有什么问题?
解决方法
在您的示例中,您只是创建了一个队列并创建了流的描述。为了运行流,您需要调用 compile
,它将公开多个方法,这将允许运行和使用流的值,如 toList
、fold
或 {{1} }
在您的情况下,您对值并不真正感兴趣,因为您只想打印它们,因此您应该使用 drain
:
drain
版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 dio@foxmail.com 举报,一经查实,本站将立刻删除。