public final class ActorRefSource<Out> extends SourceModule<Out,ActorRef>
Constructor and Description |
---|
ActorRefSource(int bufferSize,
OverflowStrategy overflowStrategy,
Attributes attributes,
SourceShape<Out> shape) |
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) |
amendShape, carbonCopy, replaceShape, shape, toString
downstreams, inPorts, outPorts, subModules, upstreams
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
compose, compose, composeNoMat, equals, fuse, fuse, hashCode, isAtomic, isBidiFlow, isCopied, isFlow, isFused, isRunnable, isSealed, isSink, isSource, materializedValueComputation, transformMaterializedValue, wire
public ActorRefSource(int bufferSize, OverflowStrategy overflowStrategy, Attributes attributes, SourceShape<Out> shape)
public Attributes attributes()
protected java.lang.String label()
label
in class SourceModule<Out,ActorRef>
public scala.Tuple2<org.reactivestreams.Publisher<Out>,ActorRef> create(MaterializationContext context)
create
in class SourceModule<Out,ActorRef>
protected SourceModule<Out,ActorRef> newInstance(SourceShape<Out> shape)
newInstance
in class SourceModule<Out,ActorRef>
public StreamLayout.AtomicModule withAttributes(Attributes attr)