akka.stream.impl

Class PublisherSource<Out>

java.lang.Object

akka.stream.impl.StreamLayout.AtomicModule

akka.stream.impl.SourceModule<Out,NotUsed>

akka.stream.impl.PublisherSource<Out>

All Implemented Interfaces:

StreamLayout.Module

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 of Processor instances that mediate the flow of elements downstream and the propagation of back-pressure upstream.

Constructor Summary

Constructors

Constructor and Description
PublisherSource(org.reactivestreams.Publisher<Out> p, Attributes attributes, SourceShape<Out> shape)

Method Summary

Modifier and Type	Method and 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)
StreamLayout.AtomicModule	withAttributes(Attributes attr)

Methods inherited from class akka.stream.impl.SourceModule

amendShape, carbonCopy, replaceShape, shape, toString

Methods inherited from class akka.stream.impl.StreamLayout.AtomicModule

downstreams, inPorts, outPorts, subModules, upstreams

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Methods inherited from interface akka.stream.impl.StreamLayout.Module

compose, compose, composeNoMat, equals, fuse, fuse, hashCode, isAtomic, isBidiFlow, isCopied, isFlow, isFused, isRunnable, isSealed, isSink, isSource, materializedValueComputation, transformMaterializedValue, wire

Constructor Detail

PublisherSource

public PublisherSource(org.reactivestreams.Publisher<Out> p,
                       Attributes attributes,
                       SourceShape<Out> shape)

Method Detail

attributes

public Attributes attributes()

label

protected java.lang.String label()

Overrides:

label in class SourceModule<Out,NotUsed>

create

public scala.Tuple2<org.reactivestreams.Publisher<Out>,NotUsed$> create(MaterializationContext context)

newInstance

protected SourceModule<Out,NotUsed> newInstance(SourceShape<Out> shape)

Specified by:

newInstance in class SourceModule<Out,NotUsed>

withAttributes

public StreamLayout.AtomicModule withAttributes(Attributes attr)