Package akka.stream.impl
Interface Pump
-
- All Known Implementing Classes:
ActorProcessorImpl
,FanIn
,FanOut
,FanoutProcessorImpl
,TLSActor
,Unzip
public interface Pump
INTERNAL API
-
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description void
akka$stream$impl$Pump$_setter_$completedPhase_$eq(TransferPhase x$1)
TransferPhase
completedPhase()
void
currentAction_$eq(scala.Function0<scala.runtime.BoxedUnit> x$1)
void
gotUpstreamSubscription()
void
initialPhase(int waitForUpstream, TransferPhase andThen)
boolean
isPumpFinished()
void
nextPhase(TransferPhase phase)
void
pump()
void
pumpFailed(java.lang.Throwable e)
void
pumpFinished()
void
transferState_$eq(TransferState x$1)
void
waitForUpstreams(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)
-
-