Package akka.stream.impl
Class SetupStage
- java.lang.Object
-
- akka.stream.impl.SetupStage
-
public class SetupStage extends java.lang.Object
-
-
Constructor Summary
Constructors Constructor Description SetupStage()
-
Method Summary
All Methods Static Methods Concrete Methods Modifier and Type Method Description static java.lang.Object
delegateToInlet(scala.Function0<scala.runtime.BoxedUnit> pull, scala.Function0<scala.runtime.BoxedUnit> cancel)
static <T> java.lang.Object
delegateToOutlet(scala.Function1<T,scala.runtime.BoxedUnit> push, scala.Function0<scala.runtime.BoxedUnit> complete, scala.Function1<java.lang.Throwable,scala.runtime.BoxedUnit> fail, GraphStageLogic.SubSinkInlet<T> subInlet)
static <T> java.lang.Object
delegateToSubInlet(GraphStageLogic.SubSinkInlet<T> subInlet)
static <T> java.lang.Object
delegateToSubOutlet(scala.Function0<T> grab, GraphStageLogic.SubSourceOutlet<T> subOutlet)
-
-
-
Method Detail
-
delegateToSubOutlet
public static <T> java.lang.Object delegateToSubOutlet(scala.Function0<T> grab, GraphStageLogic.SubSourceOutlet<T> subOutlet)
-
delegateToOutlet
public static <T> java.lang.Object delegateToOutlet(scala.Function1<T,scala.runtime.BoxedUnit> push, scala.Function0<scala.runtime.BoxedUnit> complete, scala.Function1<java.lang.Throwable,scala.runtime.BoxedUnit> fail, GraphStageLogic.SubSinkInlet<T> subInlet)
-
delegateToSubInlet
public static <T> java.lang.Object delegateToSubInlet(GraphStageLogic.SubSinkInlet<T> subInlet)
-
delegateToInlet
public static java.lang.Object delegateToInlet(scala.Function0<scala.runtime.BoxedUnit> pull, scala.Function0<scala.runtime.BoxedUnit> cancel)
-
-