FileIO.fromPath
Emits the contents of a file from the given path.
Signature
FileIO.fromPath
FileIO.fromPath
Description
Emits the contents of a file from the given path, as ByteString
s, materializes into a Future
CompletionStage
which will be completed with a IOResult
upon reaching the end of the file or if there is a failure.
Example
- Scala
-
source
import akka.stream.scaladsl._ val file = Paths.get("example.csv") val foreach: Future[IOResult] = FileIO.fromPath(file).to(Sink.ignore).run()
- Java
-
source
final Path file = Paths.get("example.csv"); Sink<ByteString, CompletionStage<Done>> printlnSink = Sink.<ByteString>foreach(chunk -> System.out.println(chunk.utf8String())); CompletionStage<IOResult> ioResult = FileIO.fromPath(file).to(printlnSink).run(system);