Package akka.stream.impl
Interface Pump
-
- All Known Implementing Classes:
ActorProcessorImpl,FanIn,FanOut,FanoutProcessorImpl,TLSActor,Unzip
public interface PumpINTERNAL API
-
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description voidakka$stream$impl$Pump$_setter_$completedPhase_$eq(TransferPhase x$1)TransferPhasecompletedPhase()voidcurrentAction_$eq(scala.Function0<scala.runtime.BoxedUnit> x$1)voidgotUpstreamSubscription()voidinitialPhase(int waitForUpstream, TransferPhase andThen)booleanisPumpFinished()voidnextPhase(TransferPhase phase)voidpump()voidpumpFailed(java.lang.Throwable e)voidpumpFinished()voidtransferState_$eq(TransferState x$1)voidwaitForUpstreams(int waitForUpstream)
-
-
-
Method Detail
-
akka$stream$impl$Pump$_setter_$completedPhase_$eq
void akka$stream$impl$Pump$_setter_$completedPhase_$eq(TransferPhase x$1)
-
completedPhase
TransferPhase completedPhase()
-
currentAction_$eq
void currentAction_$eq(scala.Function0<scala.runtime.BoxedUnit> x$1)
-
gotUpstreamSubscription
void gotUpstreamSubscription()
-
initialPhase
void initialPhase(int waitForUpstream, TransferPhase andThen)
-
isPumpFinished
boolean isPumpFinished()
-
nextPhase
void nextPhase(TransferPhase phase)
-
pump
void pump()
-
pumpFailed
void pumpFailed(java.lang.Throwable e)
-
pumpFinished
void pumpFinished()
-
transferState_$eq
void transferState_$eq(TransferState x$1)
-
waitForUpstreams
void waitForUpstreams(int waitForUpstream)
-
-