akka.stream.impl.fusing

Class SupervisedGraphStageLogic

java.lang.Object

akka.stream.stage.GraphStageLogic

akka.stream.impl.fusing.SupervisedGraphStageLogic

public abstract class SupervisedGraphStageLogic
extends GraphStageLogic

INTERNAL API

Nested Class Summary

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

GraphStageLogic.ConditionalTerminateInput, GraphStageLogic.ConditionalTerminateOutput, GraphStageLogic.EagerTerminateInput$, GraphStageLogic.EagerTerminateOutput$, GraphStageLogic.IgnoreTerminateInput$, GraphStageLogic.IgnoreTerminateOutput$, GraphStageLogic.StageActor, GraphStageLogic.StageActorRef$, GraphStageLogic.StageActorRefNotInitializedException, GraphStageLogic.StageActorRefNotInitializedException$, GraphStageLogic.SubSinkInlet<T>, GraphStageLogic.SubSourceOutlet<T>, GraphStageLogic.TotallyIgnorantInput$

Constructor Summary

Constructors

Constructor and Description
SupervisedGraphStageLogic(Attributes inheritedAttributes, Shape shape)

Method Summary

Modifier and Type	Method and Description
void	onRestart(java.lang.Throwable t)
abstract void	onResume(java.lang.Throwable t)
void	onStop(java.lang.Throwable t)
<T> scala.Option<T>	withSupervision(scala.Function0<T> f)

Methods inherited from class akka.stream.stage.GraphStageLogic

abortEmitting, abortReading, afterPostStop, beforePreStart, cancel, complete, completeStage, conditionalTerminateInput, conditionalTerminateOutput, createAsyncCallback, eagerTerminateInput, eagerTerminateOutput, emit, emit, emit, emitMultiple, emitMultiple, emitMultiple, emitMultiple, emitMultiple, emitMultiple, fail, failStage, getAsyncCallback, getHandler, getHandler, getStageActor, grab, handlers, hasBeenPulled, ignoreTerminateInput, ignoreTerminateOutput, inCount, interpreter, isAvailable, isAvailable, isClosed, isClosed, materializer, outCount, passAlong, portToConn, postStop, preStart, pull, push, read, read, readN, readN, setHandler, setHandler, setHandlers, setKeepGoing, stageActor, stageId, subFusingMaterializer, totallyIgnorantInput, tryPull

Methods inherited from class java.lang.Object

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

Constructor Detail

SupervisedGraphStageLogic

public SupervisedGraphStageLogic(Attributes inheritedAttributes,
                                 Shape shape)

Method Detail

withSupervision

public <T> scala.Option<T> withSupervision(scala.Function0<T> f)

onResume

public abstract void onResume(java.lang.Throwable t)

onStop

public void onStop(java.lang.Throwable t)

onRestart

public void onRestart(java.lang.Throwable t)