akka.stream.stage

Interface InHandler

All Known Implementing Classes:

AbstractInHandler, AbstractInOutHandler, ByteStringParser.ParsingLogic, DeflateDecompressorBase.DecompressorParsingLogic, GraphStageLogic.ConditionalTerminateInput, GraphStageLogic.EagerTerminateInput$, GraphStageLogic.IgnoreTerminateInput$, GraphStageLogic.TotallyIgnorantInput$, IteratorInterpreter.IteratorDownstream

public interface InHandler

Collection of callbacks for an input port of a GraphStage

Method Summary

Modifier and Type	Method and 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.

Method Detail

onPush

void onPush()
     throws java.lang.Exception

Called when the input port has a new element available. The actual element can be retrieved via the GraphStageLogic.grab() method.

Throws:

java.lang.Exception

onUpstreamFinish

void onUpstreamFinish()
               throws java.lang.Exception

Called when the input port is finished. After this callback no other callbacks will be called for this port.

Throws:

java.lang.Exception

onUpstreamFailure

void onUpstreamFailure(java.lang.Throwable ex)
                throws java.lang.Exception

Called when the input port has failed. After this callback no other callbacks will be called for this port.

Parameters:

ex - (undocumented)

Throws:

java.lang.Exception