public class ActorRefBackpressureSinkStage<In> extends GraphStage<SinkShape<In>>
Constructor and Description |
---|
ActorRefBackpressureSinkStage(ActorRef ref,
java.lang.Object onInitMessage,
java.lang.Object ackMessage,
java.lang.Object onCompleteMessage,
scala.Function1<java.lang.Throwable,java.lang.Object> onFailureMessage) |
Modifier and Type | Method and Description |
---|---|
GraphStageLogic |
createLogic(Attributes inheritedAttributes) |
Inlet<In> |
in() |
Attributes |
initialAttributes() |
SinkShape<In> |
shape()
The shape of a graph is all that is externally visible: its inlets and outlets.
|
java.lang.String |
toString() |
createLogicAndMaterializedValue
module, withAttributes
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
addAttributes, async, named
public ActorRefBackpressureSinkStage(ActorRef ref, java.lang.Object onInitMessage, java.lang.Object ackMessage, java.lang.Object onCompleteMessage, scala.Function1<java.lang.Throwable,java.lang.Object> onFailureMessage)
public Attributes initialAttributes()
initialAttributes
in class GraphStageWithMaterializedValue<SinkShape<In>,NotUsed>
public SinkShape<In> shape()
Graph
public GraphStageLogic createLogic(Attributes inheritedAttributes)
createLogic
in class GraphStage<SinkShape<In>>
public java.lang.String toString()
toString
in class java.lang.Object