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.

    To be thread safe this method must only be called from either the constructor of the graph operator during materialization or one of the methods invoked by the graph operator machinery, such as onPush and onPull.

    • Constructor Detail

      • SubSinkInlet

        public SubSinkInlet​(java.lang.String name)
    • Method Detail

      • cancel

        public void cancel()
      • cancel

        public void cancel​(java.lang.Throwable cause)
      • 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