Class GraphStageLogic.TotallyIgnorantInput$

  • All Implemented Interfaces:
    InHandler
    Enclosing class:
    GraphStageLogic

    public static class GraphStageLogic.TotallyIgnorantInput$
    extends java.lang.Object
    implements InHandler
    Input handler that does not terminate the operator upon receiving completion nor failure.
    • Method Summary

      All Methods Instance Methods Concrete Methods 
      Modifier and Type Method Description
      void onPush()
      Called when the input port has a new element available.
      void onUpstreamFailure​(java.lang.Throwable ex)
      Called when the input port has failed.
      void onUpstreamFinish()
      Called when the input port is finished.
      • Methods inherited from class java.lang.Object

        clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
    • Constructor Detail

      • TotallyIgnorantInput$

        public TotallyIgnorantInput$()
    • Method Detail

      • onPush

        public void onPush()
        Description copied from interface: InHandler
        Called when the input port has a new element available. The actual element can be retrieved via the {@link GraphStageLogic.grab()} method.
        Specified by:
        onPush in interface InHandler
      • onUpstreamFinish

        public void onUpstreamFinish()
        Description copied from interface: InHandler
        Called when the input port is finished. After this callback no other callbacks will be called for this port.
        Specified by:
        onUpstreamFinish in interface InHandler
      • onUpstreamFailure

        public void onUpstreamFailure​(java.lang.Throwable ex)
        Description copied from interface: InHandler
        Called when the input port has failed. After this callback no other callbacks will be called for this port.
        Specified by:
        onUpstreamFailure in interface InHandler
        Parameters:
        ex - (undocumented)