public final class ActorRefSink<In> extends SinkModule<In,NotUsed>
Constructor and Description |
---|
ActorRefSink(ActorRef ref,
java.lang.Object onCompleteMessage,
Attributes attributes,
SinkShape<In> shape) |
Modifier and Type | Method and Description |
---|---|
Attributes |
attributes() |
scala.Tuple2<org.reactivestreams.Subscriber<In>,NotUsed$> |
create(MaterializationContext context) |
protected SinkModule<In,NotUsed> |
newInstance(SinkShape<In> shape) |
StreamLayout.AtomicModule |
withAttributes(Attributes attr) |
amendShape, carbonCopy, label, 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 ActorRefSink(ActorRef ref, java.lang.Object onCompleteMessage, Attributes attributes, SinkShape<In> shape)
public Attributes attributes()
public scala.Tuple2<org.reactivestreams.Subscriber<In>,NotUsed$> create(MaterializationContext context)
protected SinkModule<In,NotUsed> newInstance(SinkShape<In> shape)
newInstance
in class SinkModule<In,NotUsed>
public StreamLayout.AtomicModule withAttributes(Attributes attr)