akka.stream.impl.io

Class FileSink

java.lang.Object

akka.stream.impl.StreamLayout.AtomicModule

akka.stream.impl.SinkModule<ByteString,scala.concurrent.Future<IOResult>>

akka.stream.impl.io.FileSink

All Implemented Interfaces:

StreamLayout.Module

public final class FileSink
extends SinkModule<ByteString,scala.concurrent.Future<IOResult>>

INTERNAL API Creates simple synchronous Sink which writes all incoming elements to the given file (creating it before hand if necessary).

Constructor Summary

Constructors

Constructor and Description
FileSink(java.nio.file.Path f, long startPosition, scala.collection.immutable.Set<java.nio.file.OpenOption> options, Attributes attributes, SinkShape<ByteString> shape)

Method Summary

Modifier and Type	Method and Description
Attributes	attributes()
scala.Tuple2<org.reactivestreams.Subscriber<ByteString>,scala.concurrent.Future<IOResult>>	create(MaterializationContext context)
protected java.lang.String	label()
protected SinkModule<ByteString,scala.concurrent.Future<IOResult>>	newInstance(SinkShape<ByteString> shape)
SinkModule<ByteString,scala.concurrent.Future<IOResult>>	withAttributes(Attributes attr)

Methods inherited from class akka.stream.impl.SinkModule

amendShape, carbonCopy, replaceShape, shape, toString

Methods inherited from class akka.stream.impl.StreamLayout.AtomicModule

downstreams, inPorts, outPorts, subModules, upstreams

Methods inherited from class java.lang.Object

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

Methods inherited from interface akka.stream.impl.StreamLayout.Module

compose, compose, composeNoMat, equals, fuse, fuse, hashCode, isAtomic, isBidiFlow, isCopied, isFlow, isFused, isRunnable, isSealed, isSink, isSource, materializedValueComputation, transformMaterializedValue, wire

Constructor Detail

FileSink

public FileSink(java.nio.file.Path f,
                long startPosition,
                scala.collection.immutable.Set<java.nio.file.OpenOption> options,
                Attributes attributes,
                SinkShape<ByteString> shape)

Method Detail

attributes

public Attributes attributes()

label

protected java.lang.String label()

Overrides:

label in class SinkModule<ByteString,scala.concurrent.Future<IOResult>>

create

public scala.Tuple2<org.reactivestreams.Subscriber<ByteString>,scala.concurrent.Future<IOResult>> create(MaterializationContext context)

newInstance

protected SinkModule<ByteString,scala.concurrent.Future<IOResult>> newInstance(SinkShape<ByteString> shape)

Specified by:

newInstance in class SinkModule<ByteString,scala.concurrent.Future<IOResult>>

withAttributes

public SinkModule<ByteString,scala.concurrent.Future<IOResult>> withAttributes(Attributes attr)