akka.stream.impl.fusing

Class RecoverWith<T,M>

java.lang.Object

akka.stream.stage.GraphStageWithMaterializedValue<S,NotUsed>

akka.stream.stage.GraphStage<FlowShape<T,T>>

akka.stream.impl.fusing.GraphStages.SimpleLinearGraphStage<T>

akka.stream.impl.fusing.RecoverWith<T,M>

All Implemented Interfaces:

Graph<FlowShape<T,T>,NotUsed>

public final class RecoverWith<T,M>
extends GraphStages.SimpleLinearGraphStage<T>

Constructor Summary

Constructors

Constructor and Description
RecoverWith(int maximumRetries, scala.PartialFunction<java.lang.Throwable,Graph<SourceShape<T>,M>> pf)

Method Summary

Modifier and Type	Method and Description
static Graph<S,M>	addAttributes(Attributes attr)
static Graph<S,M>	async()
GraphStageLogic	createLogic(Attributes attr)
static scala.Tuple2<GraphStageLogic,NotUsed>	createLogicAndMaterializedValue(Attributes inheritedAttributes)
static Inlet<T>	in()
static int	InfiniteRetries()
Attributes	initialAttributes()
int	maximumRetries()
static StreamLayout.Module	module()
static Graph<S,M>	named(java.lang.String name)
static Outlet<T>	out()
scala.PartialFunction<java.lang.Throwable,Graph<SourceShape<T>,M>>	pf()
static FlowShape<T,T>	shape()
java.lang.String	toString()
static Graph<S,M>	withAttributes(Attributes attr)

Methods inherited from class akka.stream.impl.fusing.GraphStages.SimpleLinearGraphStage

in, out, shape

Methods inherited from class akka.stream.stage.GraphStage

createLogicAndMaterializedValue

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

RecoverWith

public RecoverWith(int maximumRetries,
                   scala.PartialFunction<java.lang.Throwable,Graph<SourceShape<T>,M>> pf)

Method Detail

InfiniteRetries

public static int InfiniteRetries()

named

public static Graph<S,M> named(java.lang.String name)

async

public static Graph<S,M> async()

addAttributes

public static Graph<S,M> addAttributes(Attributes attr)

module

public static final StreamLayout.Module module()

withAttributes

public static final Graph<S,M> withAttributes(Attributes attr)

createLogicAndMaterializedValue

public static final scala.Tuple2<GraphStageLogic,NotUsed> createLogicAndMaterializedValue(Attributes inheritedAttributes)

in

public static Inlet<T> in()

out

public static Outlet<T> out()

shape

public static FlowShape<T,T> shape()

maximumRetries

public int maximumRetries()

pf

public scala.PartialFunction<java.lang.Throwable,Graph<SourceShape<T>,M>> pf()

initialAttributes

public Attributes initialAttributes()

Overrides:

initialAttributes in class GraphStageWithMaterializedValue<FlowShape<T,T>,NotUsed>

createLogic

public GraphStageLogic createLogic(Attributes attr)

Specified by:

createLogic in class GraphStage<FlowShape<T,T>>

toString

public java.lang.String toString()

Overrides:

toString in class java.lang.Object