【发布时间】:2017-12-08 16:48:46
【问题描述】:
我们正在尝试从 akka 流中读取文件。文件包含日志,应用程序很容易将日志写入新文件。但是,当运行我们的程序时,我们得到了意想不到的输出。我们的代码如下:
class LogsAkkaStream {
implicit val system = ActorSystem("AkkaStreams")
implicit val ec = system.dispatcher
implicit val materializer = ActorMaterializer()
val source: Source[ByteString, Future[IOResult]] = FileIO.fromPath(Paths.get("/home/harmeet/workspace/mylogs.logs"))
val sink: Sink[ByteString, Future[IOResult]] = FileIO.toPath(Paths.get("."), Set(CREATE, WRITE, APPEND))
val runnableGraph: RunnableGraph[Future[IOResult]] = source.to(sink)
runnableGraph.run().foreach { result =>
println(s"${result.status}, ${result.count} bytes read. ")
}
}
object LogsAkkaStream extends App {
new LogsAkkaStream
}
mylogs.logs 包含 1000 行记录,但该程序的 output 是:Success(Done), 0 bytes read. 仍然,我们没有得到实际的程序。
【问题讨论】:
标签: java scala akka actor akka-stream