Package akka.stream.impl
Class PublisherSource<Out>
- java.lang.Object
-
- akka.stream.impl.SourceModule<Out,NotUsed>
-
- akka.stream.impl.PublisherSource<Out>
-
- All Implemented Interfaces:
Graph<SourceShape<Out>,NotUsed>
,StreamLayout.AtomicModule<SourceShape<Out>,NotUsed>
public final class PublisherSource<Out> extends SourceModule<Out,NotUsed>
INTERNAL API Construct a transformation starting with given publisher. The transformation steps are executed by a series ofProcessor
instances that mediate the flow of elements downstream and the propagation of back-pressure upstream.
-
-
Constructor Summary
Constructors Constructor Description PublisherSource(org.reactivestreams.Publisher<Out> p, Attributes attributes, SourceShape<Out> shape)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description Attributes
attributes()
scala.Tuple2<org.reactivestreams.Publisher<Out>,NotUsed$>
create(MaterializationContext context)
protected java.lang.String
label()
protected SourceModule<Out,NotUsed>
newInstance(SourceShape<Out> shape)
SourceModule<Out,NotUsed>
withAttributes(Attributes attr)
-
Methods inherited from class akka.stream.impl.SourceModule
amendShape, shape, toString, traversalBuilder
-
-
-
-
Constructor Detail
-
PublisherSource
public PublisherSource(org.reactivestreams.Publisher<Out> p, Attributes attributes, SourceShape<Out> shape)
-
-
Method Detail
-
attributes
public Attributes attributes()
- Specified by:
attributes
in classSourceModule<Out,NotUsed>
-
create
public scala.Tuple2<org.reactivestreams.Publisher<Out>,NotUsed$> create(MaterializationContext context)
-
label
protected java.lang.String label()
- Overrides:
label
in classSourceModule<Out,NotUsed>
-
newInstance
protected SourceModule<Out,NotUsed> newInstance(SourceShape<Out> shape)
- Specified by:
newInstance
in classSourceModule<Out,NotUsed>
-
withAttributes
public SourceModule<Out,NotUsed> withAttributes(Attributes attr)
-
-