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

Modifier and Type	Method	Description
static java.lang.Object	delegateToInlet(scala.Function0<scala.runtime.BoxedUnit> pull, scala.Function1<java.lang.Throwable,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)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

SetupStage

public SetupStage()

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.Function1<java.lang.Throwable,scala.runtime.BoxedUnit> cancel)