public final class SubSource<T> extends GraphStage<SourceShape<T>>
Constructor and Description |
---|
SubSource(java.lang.String name,
AsyncCallback<SubSink.Command> externalCallback) |
Modifier and Type | Method and Description |
---|---|
static Graph<S,M> |
addAttributes(Attributes attr) |
static Graph<S,M> |
async() |
void |
completeSubstream() |
GraphStageLogic |
createLogic(Attributes inheritedAttributes) |
static scala.Tuple2<GraphStageLogic,NotUsed> |
createLogicAndMaterializedValue(Attributes inheritedAttributes) |
AsyncCallback<SubSink.Command> |
externalCallback() |
void |
failSubstream(java.lang.Throwable ex) |
Attributes |
initialAttributes() |
static <T,M> void |
kill(Source<T,M> s)
INTERNAL API
|
static StreamLayout.Module |
module() |
static Graph<S,M> |
named(java.lang.String name) |
Outlet<T> |
out() |
void |
pushSubstream(T elem) |
SourceShape<T> |
shape()
The shape of a graph is all that is externally visible: its inlets and outlets.
|
boolean |
timeout(scala.concurrent.duration.FiniteDuration d) |
java.lang.String |
toString() |
static Graph<S,M> |
withAttributes(Attributes attr) |
createLogicAndMaterializedValue
module, withAttributes
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
addAttributes, async, named
public SubSource(java.lang.String name, AsyncCallback<SubSink.Command> externalCallback)
public static <T,M> void kill(Source<T,M> s)
HERE ACTUALLY ARE DRAGONS, YOU HAVE BEEN WARNED!
FIXME #19240
s
- (undocumented)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 AsyncCallback<SubSink.Command> externalCallback()
public Attributes initialAttributes()
initialAttributes
in class GraphStageWithMaterializedValue<SourceShape<T>,NotUsed>
public SourceShape<T> shape()
Graph
public void pushSubstream(T elem)
public void completeSubstream()
public void failSubstream(java.lang.Throwable ex)
public boolean timeout(scala.concurrent.duration.FiniteDuration d)
public GraphStageLogic createLogic(Attributes inheritedAttributes)
createLogic
in class GraphStage<SourceShape<T>>
public java.lang.String toString()
toString
in class java.lang.Object