akka.stream.impl

Class SourceModule<Out,Mat>

java.lang.Object

akka.stream.impl.StreamLayout.AtomicModule

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

All Implemented Interfaces:

StreamLayout.Module

Direct Known Subclasses:

ActorPublisherSource, ActorRefSource, FileSource, InputStreamSource, MaybeSource, PublisherSource, StreamTestKit.ProbeSource, SubscriberSource

public abstract class SourceModule<Out,Mat>
extends StreamLayout.AtomicModule

INTERNAL API

Constructor Summary

Constructors

Constructor and Description
SourceModule(SourceShape<Out> shape)

Method Summary

Modifier and Type	Method and Description
protected SourceShape<Out>	amendShape(Attributes attr)
StreamLayout.AtomicModule	carbonCopy() The purpose of this method is to create a copy to be included in a larger graph such that port identity clashes are avoided.
abstract scala.Tuple2<org.reactivestreams.Publisher<Out>,Mat>	create(MaterializationContext context)
protected java.lang.String	label()
protected abstract SourceModule<Out,Mat>	newInstance(SourceShape<Out> shape)
StreamLayout.AtomicModule	replaceShape(Shape s) Verify that the given Shape has the same ports and return a new module with that shape.
SourceShape<Out>	shape()
java.lang.String	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

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

Constructor Detail

SourceModule

public SourceModule(SourceShape<Out> shape)

Method Detail

shape

public SourceShape<Out> shape()

label

protected java.lang.String label()

toString

public final java.lang.String toString()

Overrides:

toString in class java.lang.Object

create

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

replaceShape

public StreamLayout.AtomicModule replaceShape(Shape s)

Description copied from interface: StreamLayout.Module

Verify that the given Shape has the same ports and return a new module with that shape. Concrete implementations may throw UnsupportedOperationException where applicable.

Please note that this method MUST NOT be implemented using a CopiedModule since the purpose of replaceShape can also be to rearrange the ports (as in BidiFlow.reversed) and that purpose would be defeated.

Parameters:

s - (undocumented)

Returns:

(undocumented)

newInstance

protected abstract SourceModule<Out,Mat> newInstance(SourceShape<Out> shape)

carbonCopy

public StreamLayout.AtomicModule carbonCopy()

Description copied from interface: StreamLayout.Module

The purpose of this method is to create a copy to be included in a larger graph such that port identity clashes are avoided. Where a full copy is not possible or desirable, use a CopiedModule. The shape of the resulting module MUST NOT contain the same ports as this module&rsquo;s shape.

Returns:

(undocumented)

amendShape

protected SourceShape<Out> amendShape(Attributes attr)