出力はありません、私は次のように行毎にファイルを読み込むためにアッカFILEIOを使用していたファイル

Question

を読ん：

def main(args: Array[String]): Unit = { 
    implicit val system = ActorSystem("MySys") 
    implicit val materializer = ActorMaterializer() 
    FileIO.fromPath(Paths.get("/foo/1.csv")).via(Framing.delimiter(ByteString("\n"), 256, true).map(_.utf8String)).runForeach(println) 
    system.terminate() 
    } 

をしかし、私はこれを実行すると、私は、コンソールには何の出力を参照してくださいません。ファイルのパスが正しくあり、ファイルに内容があります。私は間違って何をしていますか？

Answer 1

ファイルを処理する前に、AkkaSystemを終了します。

この

FileIO.fromPath(Paths.get("/foo/1.csv")) 
    .via { 
    Framing.delimiter(ByteString("\n"), 256, true).map(_.utf8String) 
    } 
    .runForeach(println) 
    .onComplete{ _ => 
    system.terminate() 
    } 

Await.result(system.whenTerminated, Duration.Inf) 

Answer 2

ような何かを行う問題は、あなたが前にあなたのFuture完了し、プログラムの終了まで待機しないということです。あなたはそれを修正することができます：

def main(args: Array[String]): Unit = { 
    implicit val system = ActorSystem("MySys") 
    implicit val materializer = ActorMaterializer() 
    val future = FileIO.fromPath(Paths.get("/foo/1.csv")).via(Framing.delimiter(ByteString("\n"), 256, true).map(_.utf8String)).runForeach(println) 

    import scala.concurrent.Await 
    import scala.concurrent.duration.Duration 
    Await.result(future, Duration.Inf) 
}