Package akka.stream.impl.io

Class OutputStreamSink

java.lang.Object

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

akka.stream.impl.io.OutputStreamSink

All Implemented Interfaces:

Graph<SinkShape<ByteString>,scala.concurrent.Future<IOResult>>, StreamLayout.AtomicModule<SinkShape<ByteString>,scala.concurrent.Future<IOResult>>

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

INTERNAL API Creates simple synchronous Sink which writes all incoming elements to the output stream.

Constructor Summary

Constructors

Constructor	Description
OutputStreamSink(scala.Function0<java.io.OutputStream> createOutput, Attributes attributes, SinkShape<ByteString> shape, boolean autoFlush)

Method Summary

Modifier and Type	Method	Description
Attributes	attributes()
scala.Tuple2<org.reactivestreams.Subscriber<ByteString>,scala.concurrent.Future<IOResult>>	create(MaterializationContext context)
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, label, shape, toString, traversalBuilder

Methods inherited from class java.lang.Object

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

Methods inherited from interface akka.stream.Graph

addAttributes, async, async, async, named

Constructor Detail

OutputStreamSink

public OutputStreamSink(scala.Function0<java.io.OutputStream> createOutput,
                        Attributes attributes,
                        SinkShape<ByteString> shape,
                        boolean autoFlush)

Method Detail

attributes

public Attributes attributes()

Specified by:

attributes 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)