public final class LazySource<T,M> extends GraphStageWithMaterializedValue<SourceShape<T>,scala.concurrent.Future<M>>
| Constructor and Description |
|---|
LazySource(scala.Function0<Source<T,M>> sourceFactory) |
| Modifier and Type | Method and Description |
|---|---|
static Graph<S,M> |
addAttributes(Attributes attr) |
static <T,M> LazySource<T,M> |
apply(scala.Function0<Source<T,M>> sourceFactory) |
static Graph<S,M> |
async() |
scala.Tuple2<GraphStageLogic,scala.concurrent.Future<M>> |
createLogicAndMaterializedValue(Attributes inheritedAttributes) |
protected Attributes |
initialAttributes() |
static StreamLayout.Module |
module() |
static Graph<S,M> |
named(java.lang.String name) |
Outlet<T> |
out() |
SourceShape<T> |
shape()
The shape of a graph is all that is externally visible: its inlets and outlets.
|
java.lang.String |
toString() |
static Graph<S,M> |
withAttributes(Attributes attr) |
module, withAttributesclone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, waitaddAttributes, async, namedpublic static <T,M> LazySource<T,M> apply(scala.Function0<Source<T,M>> sourceFactory)
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 SourceShape<T> shape()
Graphprotected Attributes initialAttributes()
initialAttributes in class GraphStageWithMaterializedValue<SourceShape<T>,scala.concurrent.Future<M>>public scala.Tuple2<GraphStageLogic,scala.concurrent.Future<M>> createLogicAndMaterializedValue(Attributes inheritedAttributes)
createLogicAndMaterializedValue in class GraphStageWithMaterializedValue<SourceShape<T>,scala.concurrent.Future<M>>public java.lang.String toString()
toString in class java.lang.Object