Modifier and Type | Class and Description |
---|---|
static class |
Split.SplitAfter$
Splits after the current element.
|
static class |
Split.SplitBefore$
Splits before the current element.
|
static class |
Split.SplitDecision |
Constructor and Description |
---|
Split(Split.SplitDecision decision,
scala.Function1<T,java.lang.Object> p,
SubstreamCancelStrategy substreamCancelStrategy) |
Modifier and Type | Method and Description |
---|---|
static Graph<S,M> |
addAttributes(Attributes attr) |
static <T> Graph<FlowShape<T,Source<T,NotUsed>>,NotUsed> |
after(scala.Function1<T,java.lang.Object> p,
SubstreamCancelStrategy substreamCancelStrategy) |
static Graph<S,M> |
async() |
GraphStageLogic |
createLogic(Attributes inheritedAttributes) |
static scala.Tuple2<GraphStageLogic,NotUsed> |
createLogicAndMaterializedValue(Attributes inheritedAttributes) |
Split.SplitDecision |
decision() |
Inlet<T> |
in() |
protected static Attributes |
initialAttributes() |
static StreamLayout.Module |
module() |
static Graph<S,M> |
named(java.lang.String name) |
Outlet<Source<T,NotUsed>> |
out() |
scala.Function1<T,java.lang.Object> |
p() |
FlowShape<T,Source<T,NotUsed>> |
shape()
The shape of a graph is all that is externally visible: its inlets and outlets.
|
SubstreamCancelStrategy |
substreamCancelStrategy() |
java.lang.String |
toString() |
static <T> Graph<FlowShape<T,Source<T,NotUsed>>,NotUsed> |
when(scala.Function1<T,java.lang.Object> p,
SubstreamCancelStrategy substreamCancelStrategy) |
static Graph<S,M> |
withAttributes(Attributes attr) |
createLogicAndMaterializedValue
initialAttributes, module, withAttributes
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
addAttributes, async, named
public Split(Split.SplitDecision decision, scala.Function1<T,java.lang.Object> p, SubstreamCancelStrategy substreamCancelStrategy)
public static <T> Graph<FlowShape<T,Source<T,NotUsed>>,NotUsed> when(scala.Function1<T,java.lang.Object> p, SubstreamCancelStrategy substreamCancelStrategy)
public static <T> Graph<FlowShape<T,Source<T,NotUsed>>,NotUsed> after(scala.Function1<T,java.lang.Object> p, SubstreamCancelStrategy substreamCancelStrategy)
public static Graph<S,M> named(java.lang.String name)
public static Graph<S,M> async()
public static Graph<S,M> addAttributes(Attributes attr)
protected static Attributes initialAttributes()
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 Split.SplitDecision decision()
public scala.Function1<T,java.lang.Object> p()
public SubstreamCancelStrategy substreamCancelStrategy()
public FlowShape<T,Source<T,NotUsed>> shape()
Graph
public GraphStageLogic createLogic(Attributes inheritedAttributes)
createLogic
in class GraphStage<FlowShape<T,Source<T,NotUsed>>>
public java.lang.String toString()
toString
in class java.lang.Object