Package akka.stream.impl

Class SetupStage$

java.lang.Object

akka.stream.impl.SetupStage$

public class SetupStage$
extends java.lang.Object

Field Summary

Fields

Modifier and Type	Field	Description
static SetupStage$	MODULE$	Static reference to the singleton instance of this Scala object.

Constructor Summary

Constructors

Constructor	Description
SetupStage$()

Method Summary

Modifier and Type	Method	Description
java.lang.Object	delegateToInlet(scala.Function0<scala.runtime.BoxedUnit> pull, scala.Function0<scala.runtime.BoxedUnit> cancel)
<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)
<T> java.lang.Object	delegateToSubInlet(GraphStageLogic.SubSinkInlet<T> subInlet)
<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

Field Detail

MODULE$

public static final SetupStage$ MODULE$

Static reference to the singleton instance of this Scala object.

Constructor Detail

SetupStage$

public SetupStage$()

Method Detail

delegateToSubOutlet

public <T> java.lang.Object delegateToSubOutlet(scala.Function0<T> grab,
                                                GraphStageLogic.SubSourceOutlet<T> subOutlet)

delegateToOutlet

public <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 <T> java.lang.Object delegateToSubInlet(GraphStageLogic.SubSinkInlet<T> subInlet)

delegateToInlet

public java.lang.Object delegateToInlet(scala.Function0<scala.runtime.BoxedUnit> pull,
                                        scala.Function0<scala.runtime.BoxedUnit> cancel)