public final class InputStreamSinkStage extends GraphStageWithMaterializedValue<SinkShape<ByteString>,java.io.InputStream>
Modifier and Type | Class and Description |
---|---|
static interface |
InputStreamSinkStage.AdapterToStageMessage |
static class |
InputStreamSinkStage.Close$ |
static class |
InputStreamSinkStage.Data |
static class |
InputStreamSinkStage.Data$ |
static class |
InputStreamSinkStage.Failed |
static class |
InputStreamSinkStage.Failed$ |
static class |
InputStreamSinkStage.Finished$ |
static class |
InputStreamSinkStage.Initialized$ |
static class |
InputStreamSinkStage.ReadElementAcknowledgement$ |
static interface |
InputStreamSinkStage.StageWithCallback |
static interface |
InputStreamSinkStage.StreamToAdapterMessage |
Constructor and Description |
---|
InputStreamSinkStage(scala.concurrent.duration.FiniteDuration readTimeout) |
Modifier and Type | Method and Description |
---|---|
static Graph<S,M> |
addAttributes(Attributes attr) |
static Graph<S,M> |
async() |
scala.Tuple2<GraphStageLogic,java.io.InputStream> |
createLogicAndMaterializedValue(Attributes inheritedAttributes) |
Inlet<ByteString> |
in() |
Attributes |
initialAttributes() |
static StreamLayout.Module |
module() |
static Graph<S,M> |
named(java.lang.String name) |
SinkShape<ByteString> |
shape()
The shape of a graph is all that is externally visible: its inlets and outlets.
|
static Graph<S,M> |
withAttributes(Attributes attr) |
module, withAttributes
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
addAttributes, async, named
public InputStreamSinkStage(scala.concurrent.duration.FiniteDuration readTimeout)
public static Graph<S,M> named(java.lang.String name)
public static Graph<S,M> async()
public static Graph<S,M> addAttributes(Attributes attr)
public static final StreamLayout.Module module()
public static final Graph<S,M> withAttributes(Attributes attr)
public Inlet<ByteString> in()
public Attributes initialAttributes()
initialAttributes
in class GraphStageWithMaterializedValue<SinkShape<ByteString>,java.io.InputStream>
public SinkShape<ByteString> shape()
Graph
public scala.Tuple2<GraphStageLogic,java.io.InputStream> createLogicAndMaterializedValue(Attributes inheritedAttributes)
createLogicAndMaterializedValue
in class GraphStageWithMaterializedValue<SinkShape<ByteString>,java.io.InputStream>