public final class JavaStreamSource<T,S extends java.util.stream.BaseStream<T,S>> extends GraphStage<SourceShape<T>>
Constructor and Description |
---|
JavaStreamSource(scala.Function0<java.util.stream.BaseStream<T,S>> open) |
Modifier and Type | Method and Description |
---|---|
GraphStageLogic |
createLogic(Attributes inheritedAttributes) |
Outlet<T> |
out() |
SourceShape<T> |
shape()
The shape of a graph is all that is externally visible: its inlets and outlets.
|
createLogicAndMaterializedValue
initialAttributes, module, withAttributes
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
addAttributes, async, named
public SourceShape<T> shape()
Graph
public GraphStageLogic createLogic(Attributes inheritedAttributes)
createLogic
in class GraphStage<SourceShape<T>>