akka.stream.impl

Interface Pump

All Known Implementing Classes:

ActorProcessorImpl, FanIn, FanOut, FanoutProcessorImpl, TLSActor, Unzip

public interface Pump

INTERNAL API

Method Summary

Modifier and Type	Method and Description
TransferPhase	completedPhase()
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	waitForUpstreams(int waitForUpstream)

Method Detail

initialPhase

void initialPhase(int waitForUpstream,
                  TransferPhase andThen)

waitForUpstreams

void waitForUpstreams(int waitForUpstream)

gotUpstreamSubscription

void gotUpstreamSubscription()

nextPhase

void nextPhase(TransferPhase phase)

isPumpFinished

boolean isPumpFinished()

completedPhase

TransferPhase completedPhase()

pump

void pump()

pumpFailed

void pumpFailed(java.lang.Throwable e)

pumpFinished

void pumpFinished()