akka.stream.javadsl

Class FileIO$

java.lang.Object

akka.stream.javadsl.FileIO$

public class FileIO$
extends java.lang.Object

Factories to create sinks and sources from files

Field Summary

Fields

Modifier and Type	Field and Description
static FileIO$	MODULE$ Static reference to the singleton instance of this Scala object.

Constructor Summary

Constructors

Constructor and Description
FileIO$()

Method Summary

Modifier and Type	Method and Description
Source<ByteString,java.util.concurrent.CompletionStage<IOResult>>	fromFile(java.io.File f) Deprecated. Use `fromPath` instead. Since 2.4.5.
Source<ByteString,java.util.concurrent.CompletionStage<IOResult>>	fromFile(java.io.File f, int chunkSize) Deprecated. Use `fromPath` instead. Since 2.4.5.
Source<ByteString,java.util.concurrent.CompletionStage<IOResult>>	fromPath(java.nio.file.Path f) Creates a Source from a files contents.
Source<ByteString,java.util.concurrent.CompletionStage<IOResult>>	fromPath(java.nio.file.Path f, int chunkSize) Creates a synchronous Source from a files contents.
Source<ByteString,java.util.concurrent.CompletionStage<IOResult>>	fromPath(java.nio.file.Path f, int chunkSize, long startPosition) Creates a synchronous Source from a files contents.
Sink<ByteString,java.util.concurrent.CompletionStage<IOResult>>	toFile(java.io.File f) Deprecated. Use `toPath` instead. Since 2.4.5.
<Opt extends java.nio.file.OpenOption> Sink<ByteString,java.util.concurrent.CompletionStage<IOResult>>	toFile(java.io.File f, java.util.Set<Opt> options) Deprecated. Use `toPath` instead. Since 2.4.5.
Sink<ByteString,java.util.concurrent.CompletionStage<IOResult>>	toPath(java.nio.file.Path f) Creates a Sink that writes incoming ByteString elements to the given file path.
<Opt extends java.nio.file.OpenOption> Sink<ByteString,java.util.concurrent.CompletionStage<IOResult>>	toPath(java.nio.file.Path f, java.util.Set<Opt> options) Creates a Sink that writes incoming ByteString elements to the given file path.
<Opt extends java.nio.file.OpenOption> Sink<ByteString,java.util.concurrent.CompletionStage<IOResult>>	toPath(java.nio.file.Path f, java.util.Set<Opt> options, long startPosition) Creates a Sink that writes incoming ByteString elements to the given file path.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

MODULE$

public static final FileIO$ MODULE$

Static reference to the singleton instance of this Scala object.

Constructor Detail

FileIO$

public FileIO$()

Method Detail

toFile

public Sink<ByteString,java.util.concurrent.CompletionStage<IOResult>> toFile(java.io.File f)

Deprecated. Use `toPath` instead. Since 2.4.5.

Creates a Sink that writes incoming ByteString elements to the given file. Overwrites existing files by truncating their contents, if you want to append to an existing file use #toFile(File, util.Set[OpenOption]) with java.nio.file.StandardOpenOption.APPEND.

Materializes a CompletionStage of 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.

You can configure the default dispatcher for this Source by changing the akka.stream.blocking-io-dispatcher or set it for a given Source by using ActorAttributes.

Parameters:

f - The file to write to

Returns:

(undocumented)

toPath

public Sink<ByteString,java.util.concurrent.CompletionStage<IOResult>> toPath(java.nio.file.Path f)

Creates a Sink that writes incoming ByteString elements to the given file path. Overwrites existing files by truncating their contents, if you want to append to an existing file #toPath(Path, util.Set[OpenOption]) with java.nio.file.StandardOpenOption.APPEND.

Materializes a CompletionStage of 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.

You can configure the default dispatcher for this Source by changing the akka.stream.blocking-io-dispatcher or set it for a given Source by using ActorAttributes.

Parameters:

f - The file path to write to

Returns:

(undocumented)

toFile

public <Opt extends java.nio.file.OpenOption> Sink<ByteString,java.util.concurrent.CompletionStage<IOResult>> toFile(java.io.File f,
                                                                                                                     java.util.Set<Opt> options)

Deprecated. Use `toPath` instead. Since 2.4.5.

Creates a Sink that writes incoming ByteString elements to the given file.

Materializes a CompletionStage of 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.

You can configure the default dispatcher for this Source by changing the akka.stream.blocking-io-dispatcher or set it for a given Source by using ActorAttributes.

Parameters:

f - The file to write to

options - File open options, see StandardOpenOption

Returns:

(undocumented)

toPath

public <Opt extends java.nio.file.OpenOption> Sink<ByteString,java.util.concurrent.CompletionStage<IOResult>> toPath(java.nio.file.Path f,
                                                                                                                     java.util.Set<Opt> options)

Creates a Sink that writes incoming ByteString elements to the given file path.

Materializes a CompletionStage of 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.

You can configure the default dispatcher for this Source by changing the akka.stream.blocking-io-dispatcher or set it for a given Source by using ActorAttributes.

Parameters:

f - The file path to write to

options - File open options, see StandardOpenOption

Returns:

(undocumented)

toPath

public <Opt extends java.nio.file.OpenOption> Sink<ByteString,java.util.concurrent.CompletionStage<IOResult>> toPath(java.nio.file.Path f,
                                                                                                                     java.util.Set<Opt> options,
                                                                                                                     long startPosition)

Creates a Sink that writes incoming ByteString elements to the given file path.

Materializes a CompletionStage of 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.

You can configure the default dispatcher for this Source by changing the akka.stream.blocking-io-dispatcher or set it for a given Source by using ActorAttributes.

Parameters:

f - The file path to write to

options - File open options, see StandardOpenOption

startPosition - startPosition the start position to read from, defaults to 0

Returns:

(undocumented)

fromFile

public Source<ByteString,java.util.concurrent.CompletionStage<IOResult>> fromFile(java.io.File f)

Deprecated. Use `fromPath` instead. Since 2.4.5.

Creates a Source from a files contents. Emitted elements are ByteString elements, chunked by default by 8192 bytes, except the last element, which will be up to 8192 in size.

You can configure the default dispatcher for this Source by changing the akka.stream.blocking-io-dispatcher or set it for a given Source by using ActorAttributes.

It materializes a CompletionStage of IOResult containing the number of bytes read from the source file upon completion, and a possible exception if IO operation was not completed successfully.

Parameters:

f - the file to read from

Returns:

(undocumented)

fromPath

public Source<ByteString,java.util.concurrent.CompletionStage<IOResult>> fromPath(java.nio.file.Path f)

Creates a Source from a files contents. Emitted elements are ByteString elements, chunked by default by 8192 bytes, except the last element, which will be up to 8192 in size.

You can configure the default dispatcher for this Source by changing the akka.stream.blocking-io-dispatcher or set it for a given Source by using ActorAttributes.

It materializes a CompletionStage of IOResult containing the number of bytes read from the source file upon completion, and a possible exception if IO operation was not completed successfully.

Parameters:

f - the file path to read from

Returns:

(undocumented)

fromFile

public Source<ByteString,java.util.concurrent.CompletionStage<IOResult>> fromFile(java.io.File f,
                                                                                  int chunkSize)

Deprecated. Use `fromPath` instead. Since 2.4.5.

Creates a synchronous Source from a files contents. Emitted elements are chunkSize sized ByteString elements, except the last element, which will be up to chunkSize in size.

You can configure the default dispatcher for this Source by changing the akka.stream.blocking-io-dispatcher or set it for a given Source by using ActorAttributes.

It materializes a CompletionStage of IOResult containing the number of bytes read from the source file upon completion, and a possible exception if IO operation was not completed successfully.

Parameters:

f - the file to read from

chunkSize - the size of each read operation

Returns:

(undocumented)

fromPath

public Source<ByteString,java.util.concurrent.CompletionStage<IOResult>> fromPath(java.nio.file.Path f,
                                                                                  int chunkSize)

Creates a synchronous Source from a files contents. Emitted elements are chunkSize sized ByteString elements, except the last element, which will be up to chunkSize in size.

You can configure the default dispatcher for this Source by changing the akka.stream.blocking-io-dispatcher or set it for a given Source by using ActorAttributes.

It materializes a CompletionStage of IOResult containing the number of bytes read from the source file upon completion, and a possible exception if IO operation was not completed successfully.

Parameters:

f - the file path to read from

chunkSize - the size of each read operation

Returns:

(undocumented)

fromPath

public Source<ByteString,java.util.concurrent.CompletionStage<IOResult>> fromPath(java.nio.file.Path f,
                                                                                  int chunkSize,
                                                                                  long startPosition)

Creates a synchronous Source from a files contents. Emitted elements are chunkSize sized ByteString elements, except the last element, which will be up to chunkSize in size.

You can configure the default dispatcher for this Source by changing the akka.stream.blocking-io-dispatcher or set it for a given Source by using ActorAttributes.

It materializes a CompletionStage of IOResult containing the number of bytes read from the source file upon completion, and a possible exception if IO operation was not completed successfully.

Parameters:

f - the file path to read from

chunkSize - the size of each read operation

startPosition - startPosition the start position to read from, defaults to 0

Returns:

(undocumented)