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-most Publisher 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

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

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Methods inherited from interface akka.stream.Graph

addAttributes, async, async, async, named

Constructor Detail

PublisherSink

public PublisherSink(Attributes attributes,
                     SinkShape<In> shape)

Method Detail

attributes

public Attributes attributes()

Specified by:

attributes in class SinkModule<In,org.reactivestreams.Publisher<In>>

create

public scala.Tuple2<java.lang.Object,org.reactivestreams.Publisher<In>> create(MaterializationContext context)

Specified by:

create in class SinkModule<In,org.reactivestreams.Publisher<In>>

newInstance

protected SinkModule<In,org.reactivestreams.Publisher<In>> newInstance(SinkShape<In> shape)

Specified by:

newInstance in class SinkModule<In,org.reactivestreams.Publisher<In>>

withAttributes

public SinkModule<In,org.reactivestreams.Publisher<In>> withAttributes(Attributes attr)