Package akka.stream.impl
Class ActorRefSink<In>
- java.lang.Object
-
- akka.stream.impl.SinkModule<In,NotUsed>
-
- akka.stream.impl.ActorRefSink<In>
-
- All Implemented Interfaces:
Graph<SinkShape<In>,NotUsed>
,StreamLayout.AtomicModule<SinkShape<In>,NotUsed>
public final class ActorRefSink<In> extends SinkModule<In,NotUsed>
INTERNAL API
-
-
Constructor Summary
Constructors Constructor Description ActorRefSink(ActorRef ref, java.lang.Object onCompleteMessage, scala.Function1<java.lang.Throwable,java.lang.Object> onFailureMessage, Attributes attributes, SinkShape<In> shape)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description Attributes
attributes()
scala.Tuple2<org.reactivestreams.Subscriber<In>,NotUsed$>
create(MaterializationContext context)
protected SinkModule<In,NotUsed>
newInstance(SinkShape<In> shape)
SinkModule<In,NotUsed>
withAttributes(Attributes attr)
-
Methods inherited from class akka.stream.impl.SinkModule
amendShape, label, shape, toString, traversalBuilder
-
-
-
-
Constructor Detail
-
ActorRefSink
public ActorRefSink(ActorRef ref, java.lang.Object onCompleteMessage, scala.Function1<java.lang.Throwable,java.lang.Object> onFailureMessage, Attributes attributes, SinkShape<In> shape)
-
-
Method Detail
-
attributes
public Attributes attributes()
- Specified by:
attributes
in classSinkModule<In,NotUsed>
-
create
public scala.Tuple2<org.reactivestreams.Subscriber<In>,NotUsed$> create(MaterializationContext context)
-
newInstance
protected SinkModule<In,NotUsed> newInstance(SinkShape<In> shape)
- Specified by:
newInstance
in classSinkModule<In,NotUsed>
-
withAttributes
public SinkModule<In,NotUsed> withAttributes(Attributes attr)
-
-