akka.stream.stage

Class PushStage<In,Out>

java.lang.Object

akka.stream.stage.AbstractStage<In,Out,SyncDirective,SyncDirective,Context<Out>,LifecycleContext>

akka.stream.stage.PushPullStage<In,Out>

akka.stream.stage.PushStage<In,Out>

All Implemented Interfaces:

Stage<In,Out>

Deprecated.

Please use GraphStage instead. Since 2.4.2.

public abstract class PushStage<In,Out>
extends PushPullStage<In,Out>

PushStage is a PushPullStage that always perform transitive pull by calling ctx.pull from onPull.

Nested Class Summary

Nested classes/interfaces inherited from class akka.stream.stage.AbstractStage

AbstractStage.PushPullGraphStage<In,Out,Ext>, AbstractStage.PushPullGraphStageWithMaterializedValue<In,Out,Ext,Mat>

Constructor Summary

Constructors

Constructor and Description
PushStage() Deprecated.

Method Summary

Modifier and Type	Method and Description
SyncDirective	onPull(Context<Out> ctx) Deprecated. Always pulls from upstream.

Methods inherited from class akka.stream.stage.AbstractStage

decide, isDetached, onDownstreamFinish, onPush, onUpstreamFailure, onUpstreamFinish, postStop, preStart, restart

Methods inherited from class java.lang.Object

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

Constructor Detail

PushStage

public PushStage()

Deprecated.

Method Detail

onPull

public final SyncDirective onPull(Context<Out> ctx)

Deprecated.

Always pulls from upstream.

Specified by:

onPull in class AbstractStage<In,Out,SyncDirective,SyncDirective,Context<Out>,LifecycleContext>

Parameters:

ctx - (undocumented)

Returns:

(undocumented)