Package akka.stream.impl
Class PublisherSink<In>
- java.lang.Object
-
- akka.stream.impl.SinkModule<In,org.reactivestreams.Publisher<In>>
-
- akka.stream.impl.PublisherSink<In>
-
- All Implemented Interfaces:
Graph<SinkShape<In>,org.reactivestreams.Publisher<In>>
,StreamLayout.AtomicModule<SinkShape<In>,org.reactivestreams.Publisher<In>>
public class PublisherSink<In> extends SinkModule<In,org.reactivestreams.Publisher<In>>
INTERNAL API Holds the downstream-mostPublisher
interface of the materialized flow. The stream will not have any subscribers attached at this point, which means that after prefetching elements to fill the internal buffers it will assert back-pressure until a subscriber connects and creates demand for elements to be emitted.
-
-
Constructor Summary
Constructors Constructor Description PublisherSink(Attributes attributes, SinkShape<In> shape)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description Attributes
attributes()
scala.Tuple2<java.lang.Object,org.reactivestreams.Publisher<In>>
create(MaterializationContext context)
protected SinkModule<In,org.reactivestreams.Publisher<In>>
newInstance(SinkShape<In> shape)
SinkModule<In,org.reactivestreams.Publisher<In>>
withAttributes(Attributes attr)
-
Methods inherited from class akka.stream.impl.SinkModule
amendShape, label, shape, toString, traversalBuilder
-
-
-
-
Constructor Detail
-
PublisherSink
public PublisherSink(Attributes attributes, SinkShape<In> shape)
-
-
Method Detail
-
attributes
public Attributes attributes()
- Specified by:
attributes
in classSinkModule<In,org.reactivestreams.Publisher<In>>
-
create
public scala.Tuple2<java.lang.Object,org.reactivestreams.Publisher<In>> create(MaterializationContext context)
- Specified by:
create
in classSinkModule<In,org.reactivestreams.Publisher<In>>
-
newInstance
protected SinkModule<In,org.reactivestreams.Publisher<In>> newInstance(SinkShape<In> shape)
- Specified by:
newInstance
in classSinkModule<In,org.reactivestreams.Publisher<In>>
-
withAttributes
public SinkModule<In,org.reactivestreams.Publisher<In>> withAttributes(Attributes attr)
-
-