ソース[ByteString、Future [IOResult]]をリスト[String]に変換してください

Question

ファイルを読み取ろうとしています。このファイルを1行ずつリストに読み込む必要があります。

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

どのようにして、res値をList [String]に変換できますか？

Answer 1

コメントの流れは良い出発点のようです。 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)