Package akka.stream.impl
Class SourceModule<Out,Mat>
- java.lang.Object
-
- akka.stream.impl.SourceModule<Out,Mat>
-
- All Implemented Interfaces:
Graph<SourceShape<Out>,Mat>,StreamLayout.AtomicModule<SourceShape<Out>,Mat>
- Direct Known Subclasses:
ActorPublisherSource,InputStreamSource,PublisherSource,StreamTestKit.ProbeSource,SubscriberSource
public abstract class SourceModule<Out,Mat> extends java.lang.Object implements StreamLayout.AtomicModule<SourceShape<Out>,Mat>
INTERNAL API
-
-
Constructor Summary
Constructors Constructor Description SourceModule(SourceShape<Out> shape)
-
Method Summary
All Methods Instance Methods Abstract Methods Concrete Methods Modifier and Type Method Description protected SourceShape<Out>amendShape(Attributes attr)abstract Attributesattributes()abstract scala.Tuple2<org.reactivestreams.Publisher<Out>,Mat>create(MaterializationContext context)protected java.lang.Stringlabel()protected abstract SourceModule<Out,Mat>newInstance(SourceShape<Out> shape)SourceShape<Out>shape()The shape of a graph is all that is externally visible: its inlets and outlets.java.lang.StringtoString()LinearTraversalBuildertraversalBuilder()INTERNAL API.-
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
-
Methods inherited from interface akka.stream.Graph
addAttributes, async, async, async, named, withAttributes
-
-
-
-
Constructor Detail
-
SourceModule
public SourceModule(SourceShape<Out> shape)
-
-
Method Detail
-
amendShape
protected SourceShape<Out> amendShape(Attributes attr)
-
attributes
public abstract Attributes attributes()
-
create
public abstract scala.Tuple2<org.reactivestreams.Publisher<Out>,Mat> create(MaterializationContext context)
-
label
protected java.lang.String label()
-
newInstance
protected abstract SourceModule<Out,Mat> newInstance(SourceShape<Out> shape)
-
shape
public SourceShape<Out> shape()
Description copied from interface:GraphThe shape of a graph is all that is externally visible: its inlets and outlets.
-
toString
public final java.lang.String toString()
- Overrides:
toStringin classjava.lang.Object
-
traversalBuilder
public LinearTraversalBuilder traversalBuilder()
Description copied from interface:GraphINTERNAL API.Every materializable element must be backed by a stream layout module
- Specified by:
traversalBuilderin interfaceGraph<Out,Mat>- Returns:
- (undocumented)
-
-