akka.stream.impl

Class ActorRefSource<Out>

java.lang.Object

akka.stream.impl.StreamLayout.AtomicModule

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

akka.stream.impl.ActorRefSource<Out>

All Implemented Interfaces:

StreamLayout.Module

public final class ActorRefSource<Out>
extends SourceModule<Out,ActorRef>

INTERNAL API

Constructor Summary

Constructors

Constructor and Description
ActorRefSource(int bufferSize, OverflowStrategy overflowStrategy, Attributes attributes, SourceShape<Out> shape)

Method Summary

Modifier and Type	Method and Description
Attributes	attributes()
scala.Tuple2<org.reactivestreams.Publisher<Out>,ActorRef>	create(MaterializationContext context)
protected java.lang.String	label()
protected SourceModule<Out,ActorRef>	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

ActorRefSource

public ActorRefSource(int bufferSize,
                      OverflowStrategy overflowStrategy,
                      Attributes attributes,
                      SourceShape<Out> shape)

Method Detail

attributes

public Attributes attributes()

label

protected java.lang.String label()

Overrides:

label in class SourceModule<Out,ActorRef>

create

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

Specified by:

create in class SourceModule<Out,ActorRef>

newInstance

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

Specified by:

newInstance in class SourceModule<Out,ActorRef>

withAttributes

public StreamLayout.AtomicModule withAttributes(Attributes attr)