Package org.apache.pekko.stream.stage

Interface InHandler

All Known Implementing Classes:
AbstractInHandler, AbstractInOutHandler, GraphStageLogic.ConditionalTerminateInput, GraphStageLogic.EagerTerminateInput$, GraphStageLogic.IgnoreTerminateInput$, GraphStageLogic.TotallyIgnorantInput$
public interface InHandler
Collection of callbacks for an input port of a GraphStage

  • Method Summary

    Modifier and Type
    Method
    Description
    void
    onPush()
    Called when the input port has a new element available.
    void
    onUpstreamFailure(Throwable ex)
    Called when the input port has failed.
    void
    onUpstreamFinish()
    Called when the input port is finished.

  • Method Details

    • onPush

      void onPush() throws Exception
      Called when the input port has a new element available. The actual element can be retrieved via the GraphStageLogic.grab method.
      Throws:
      Exception

    • onUpstreamFailure

      void onUpstreamFailure(Throwable ex) throws Exception
      Called when the input port has failed. After this callback no other callbacks will be called for this port.
      Throws:
      Exception

    • onUpstreamFinish

      void onUpstreamFinish() throws Exception
      Called when the input port is finished. After this callback no other callbacks will be called for this port.
      Throws:
      Exception