Interface Pump

    • Method Detail

      • akka$stream$impl$Pump$_setter_$completedPhase_$eq

        void akka$stream$impl$Pump$_setter_$completedPhase_$eq​(TransferPhase x$1)
      • 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()
      • 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)