我正在尝试读取文件。我需要逐行将此文件读入列表。

val res: stream.scaladsl.Source[ByteString, Future[IOResult]] = Ftp.fromPath(Paths.get(uri), ftpSettings)

如何将res值转换为List [String]?

最佳答案

您的评论流程似乎是一个很好的起点。
尝试针对Sink.seq运行它。

  val f: Future[Seq[String]] = res
    .via(Framing.delimiter( ByteString("\n"), maximumFrameLength = 256, allowTruncation = true))
    .map(_.utf8String)
    .runWith(Sink.seq)

  val list: Seq[String] = Await.result(f, 10.seconds)

09-30 15:34
查看更多