public final class UnfoldAsync<S,E> extends GraphStage<SourceShape<E>>
Constructor and Description |
---|
UnfoldAsync(S s,
scala.Function1<S,scala.concurrent.Future<scala.Option<scala.Tuple2<S,E>>>> f) |
Modifier and Type | Method and Description |
---|---|
GraphStageLogic |
createLogic(Attributes inheritedAttributes) |
Attributes |
initialAttributes() |
Outlet<E> |
out() |
SourceShape<E> |
shape()
The shape of a graph is all that is externally visible: its inlets and outlets.
|
createLogicAndMaterializedValue
module, withAttributes
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
addAttributes, async, named
public SourceShape<E> shape()
Graph
public Attributes initialAttributes()
initialAttributes
in class GraphStageWithMaterializedValue<SourceShape<E>,NotUsed>
public GraphStageLogic createLogic(Attributes inheritedAttributes)
createLogic
in class GraphStage<SourceShape<E>>