Class ActorGraphInterpreter.ActorOutputBoundary

    • Constructor Detail

      • ActorOutputBoundary

        public ActorOutputBoundary​(GraphInterpreterShell shell,
                                   java.lang.String internalPortName)
    • Method Detail

      • cancel

        public void cancel​(java.lang.Throwable cause)
      • downstreamCompleted

        public boolean downstreamCompleted()
      • fail

        public void fail​(java.lang.Throwable e)
      • internalPortName

        public java.lang.String internalPortName()
      • 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 GraphStageLogic.grab method.
        Specified by:
        onPush in interface InHandler
      • onUpstreamFailure

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

        public void requestMore​(long elements)
      • setActor

        public void setActor​(ActorRef actor)
      • subscribePending

        public void subscribePending()