public final class OutputStreamSink extends SinkModule<ByteString,scala.concurrent.Future<IOResult>>
Constructor and Description |
---|
OutputStreamSink(scala.Function0<java.io.OutputStream> createOutput,
Attributes attributes,
SinkShape<ByteString> shape,
boolean autoFlush) |
Modifier and Type | Method and 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) |
amendShape, carbonCopy, label, replaceShape, shape, toString
downstreams, inPorts, outPorts, subModules, upstreams
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
compose, compose, composeNoMat, equals, fuse, fuse, hashCode, isAtomic, isBidiFlow, isCopied, isFlow, isFused, isRunnable, isSealed, isSink, isSource, materializedValueComputation, transformMaterializedValue, wire
public OutputStreamSink(scala.Function0<java.io.OutputStream> createOutput, Attributes attributes, SinkShape<ByteString> shape, boolean autoFlush)
public Attributes attributes()
public scala.Tuple2<org.reactivestreams.Subscriber<ByteString>,scala.concurrent.Future<IOResult>> create(MaterializationContext context)
protected SinkModule<ByteString,scala.concurrent.Future<IOResult>> newInstance(SinkShape<ByteString> shape)
newInstance
in class SinkModule<ByteString,scala.concurrent.Future<IOResult>>
public SinkModule<ByteString,scala.concurrent.Future<IOResult>> withAttributes(Attributes attr)