Class 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.