akka.stream.stage

Class AbstractStage.PushPullGraphStage<In,Out,Ext>

java.lang.Object

akka.stream.stage.GraphStageWithMaterializedValue<FlowShape<In,Out>,Mat>

akka.stream.stage.AbstractStage.PushPullGraphStageWithMaterializedValue<In,Out,Ext,NotUsed>

akka.stream.stage.AbstractStage.PushPullGraphStage<In,Out,Ext>

All Implemented Interfaces:

Graph<FlowShape<In,Out>,NotUsed>

Direct Known Subclasses:

Stages.SymbolicGraphStage

Enclosing class:

AbstractStage<In,Out,PushD extends Directive,PullD extends Directive,Ctx extends Context<Out>,LifeCtx extends LifecycleContext>

public static class AbstractStage.PushPullGraphStage<In,Out,Ext>
extends AbstractStage.PushPullGraphStageWithMaterializedValue<In,Out,Ext,NotUsed>

Constructor Summary

Constructors

Constructor and Description
PushPullGraphStage(scala.Function1<Attributes,Stage<In,Out>> _factory, Attributes _stageAttributes)

Method Summary

Methods inherited from class akka.stream.stage.AbstractStage.PushPullGraphStageWithMaterializedValue

createLogicAndMaterializedValue, factory, initialAttributes, name, shape, toString

Methods inherited from class akka.stream.stage.GraphStageWithMaterializedValue

module, withAttributes

Methods inherited from class java.lang.Object

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

Methods inherited from interface akka.stream.Graph

addAttributes, async, named

Constructor Detail

PushPullGraphStage

public PushPullGraphStage(scala.Function1<Attributes,Stage<In,Out>> _factory,
                          Attributes _stageAttributes)