Scala 逐行调度流响应

我正在尝试使用 Scala 调度，但既是 Scala 新手，又面对 Dispatch api 符号疯狂的问题，我对如何流式传输大型 http 响应并逐行处理它感到困惑。任何帮助，将不胜感激。

干杯，克里斯。

Note:

这对我不起作用：

Http(url(Config.publisherUrl) > as.stream.Lines(line => println(line)))

这些行永远不会被打印。

Edit:

正在打印这些行，但仅当响应中有多于一行时才打印。问题似乎是我可以逐行传输数据，但最后一行被省略。

我有同样的问题。你能做什么。我将其作为输入流读取，然后将其转换为 Akka 流并返回源。

import akka.stream.scaladsl.{Source, StreamConverters}
  val futureStream = Http(url(urlString) > as.Response(_.getResponseBodyAsStream))
        futureStream.map { inputStream =>
          val source = () => inputStream
          StreamConverters.fromInputStream(source)
        }

这对我有用。