Package akka.stream.impl
Class CancelSink
- java.lang.Object
-
- akka.stream.impl.SinkModule<java.lang.Object,NotUsed>
-
- akka.stream.impl.CancelSink
-
- All Implemented Interfaces:
Graph<SinkShape<java.lang.Object>,NotUsed>
,StreamLayout.AtomicModule<SinkShape<java.lang.Object>,NotUsed>
public final class CancelSink extends SinkModule<java.lang.Object,NotUsed>
INTERNAL API A sink that immediately cancels its upstream upon materialization.
-
-
Nested Class Summary
-
Nested classes/interfaces inherited from interface akka.stream.Graph
Graph.GraphMapMatVal<S extends Shape,M>
-
-
Constructor Summary
Constructors Constructor Description CancelSink(Attributes attributes, SinkShape<java.lang.Object> shape)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description Attributes
attributes()
scala.Tuple2<org.reactivestreams.Subscriber<java.lang.Object>,NotUsed>
create(MaterializationContext context)
SinkModule<java.lang.Object,NotUsed>
withAttributes(Attributes attr)
-
Methods inherited from class akka.stream.impl.SinkModule
amendShape, label, shape, toString, traversalBuilder
-
-
-
-
Constructor Detail
-
CancelSink
public CancelSink(Attributes attributes, SinkShape<java.lang.Object> shape)
-
-
Method Detail
-
attributes
public Attributes attributes()
- Specified by:
attributes
in classSinkModule<java.lang.Object,NotUsed>
-
create
public scala.Tuple2<org.reactivestreams.Subscriber<java.lang.Object>,NotUsed> create(MaterializationContext context)
-
withAttributes
public SinkModule<java.lang.Object,NotUsed> withAttributes(Attributes attr)
-
-