Package akka.stream.stage
Class GraphStageLogic.SubSinkInlet<T>
- java.lang.Object
-
- akka.stream.stage.GraphStageLogic.SubSinkInlet<T>
-
- Enclosing class:
- GraphStageLogic
public class GraphStageLogic.SubSinkInlet<T> extends java.lang.Object
INTERNAL APIThis allows the dynamic creation of an Inlet for a GraphStage which is connected to a Sink that is available for materialization (e.g. using the
subFusingMaterializer
). Care needs to be taken to cancel this Inlet when the operator shuts down lest the corresponding Sink be left hanging.
-
-
Constructor Summary
Constructors Constructor Description SubSinkInlet(java.lang.String name)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description void
cancel()
T
grab()
boolean
hasBeenPulled()
boolean
isAvailable()
boolean
isClosed()
void
pull()
void
setHandler(InHandler handler)
Graph<SinkShape<T>,NotUsed>
sink()
java.lang.String
toString()
-
-
-
Method Detail
-
cancel
public void cancel()
-
grab
public T grab()
-
hasBeenPulled
public boolean hasBeenPulled()
-
isAvailable
public boolean isAvailable()
-
isClosed
public boolean isClosed()
-
pull
public void pull()
-
setHandler
public void setHandler(InHandler handler)
-
toString
public java.lang.String toString()
- Overrides:
toString
in classjava.lang.Object
-
-