public abstract class PushStage<In,Out> extends PushPullStage<In,Out>
AbstractStage.PushPullGraphStage<In,Out,Ext>, AbstractStage.PushPullGraphStageWithMaterializedValue<In,Out,Ext,Mat>
Constructor and Description |
---|
PushStage()
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
SyncDirective |
onPull(Context<Out> ctx)
Deprecated.
Always pulls from upstream.
|
decide, isDetached, onDownstreamFinish, onPush, onUpstreamFailure, onUpstreamFinish, postStop, preStart, restart
public final SyncDirective onPull(Context<Out> ctx)
onPull
in class AbstractStage<In,Out,SyncDirective,SyncDirective,Context<Out>,LifecycleContext>
ctx
- (undocumented)