Create a sink which will write incoming
ByteString s to a given file path.
File IO Sinks and Sources
Creates a Sink which writes incoming
ByteString elements to the given file path. Overwrites existing files by truncating their contents as default. Materializes a
IOResult that will be completed with the size of the file (in bytes) at the streams completion, and a possible exception if IO operation was not completed successfully.
val file = Paths.get("greeting.txt")
val text = Source.single("Hello Akka Stream!")
val result: Future[IOResult] = text.map(t => ByteString(t)).runWith(FileIO.toPath(file))
final Path file = Paths.get("greeting.txt");
Sink<ByteString, CompletionStage<IOResult>> fileSink = FileIO.toPath(file);
Source<String, NotUsed> textSource = Source.single("Hello Akka Stream!");
CompletionStage<IOResult> ioResult =
Found an error in this documentation? The source code for this page can be found here
Please feel free to edit and contribute a pull request.