public final class RecoverWith<T,M> extends GraphStages.SimpleLinearGraphStage<T>
Constructor and Description |
---|
RecoverWith(int maximumRetries,
scala.PartialFunction<java.lang.Throwable,Graph<SourceShape<T>,M>> pf) |
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) |
in, out, shape
createLogicAndMaterializedValue
module, withAttributes
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
addAttributes, async, named
public RecoverWith(int maximumRetries, scala.PartialFunction<java.lang.Throwable,Graph<SourceShape<T>,M>> pf)
public static int InfiniteRetries()
public static Graph<S,M> named(java.lang.String name)
public static Graph<S,M> async()
public static Graph<S,M> addAttributes(Attributes attr)
public static final StreamLayout.Module module()
public static final Graph<S,M> withAttributes(Attributes attr)
public static final scala.Tuple2<GraphStageLogic,NotUsed> createLogicAndMaterializedValue(Attributes inheritedAttributes)
public static Inlet<T> in()
public static Outlet<T> out()
public static FlowShape<T,T> shape()
public int maximumRetries()
public scala.PartialFunction<java.lang.Throwable,Graph<SourceShape<T>,M>> pf()
public Attributes initialAttributes()
initialAttributes
in class GraphStageWithMaterializedValue<FlowShape<T,T>,NotUsed>
public GraphStageLogic createLogic(Attributes attr)
createLogic
in class GraphStage<FlowShape<T,T>>
public java.lang.String toString()
toString
in class java.lang.Object