Class GraphStageLogic.SubSinkInlet<T>

  • Enclosing class:
    GraphStageLogic

    public class GraphStageLogic.SubSinkInlet<T>
    extends java.lang.Object
    INTERNAL API

    This 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 Detail

      • SubSinkInlet

        public SubSinkInlet​(java.lang.String name)
    • 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 class java.lang.Object