public class PublisherSink<In> extends SinkModule<In,org.reactivestreams.Publisher<In>>
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 and Description |
---|
PublisherSink(Attributes attributes,
SinkShape<In> shape) |
Modifier and Type | Method and Description |
---|---|
Attributes |
attributes() |
scala.Tuple2<java.lang.Object,org.reactivestreams.Publisher<In>> |
create(MaterializationContext context)
Create the Subscriber or VirtualPublisher that consumes the incoming
stream, plus the materialized value.
|
protected SinkModule<In,org.reactivestreams.Publisher<In>> |
newInstance(SinkShape<In> shape) |
StreamLayout.AtomicModule |
withAttributes(Attributes attr) |
amendShape, carbonCopy, label, replaceShape, shape, toString
downstreams, inPorts, outPorts, subModules, upstreams
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
compose, compose, composeNoMat, equals, fuse, fuse, hashCode, isAtomic, isBidiFlow, isCopied, isFlow, isFused, isRunnable, isSealed, isSink, isSource, materializedValueComputation, transformMaterializedValue, wire
public PublisherSink(Attributes attributes, SinkShape<In> shape)
public Attributes attributes()
public scala.Tuple2<java.lang.Object,org.reactivestreams.Publisher<In>> create(MaterializationContext context)
SinkModule
create
in class SinkModule<In,org.reactivestreams.Publisher<In>>
context
- (undocumented)protected SinkModule<In,org.reactivestreams.Publisher<In>> newInstance(SinkShape<In> shape)
newInstance
in class SinkModule<In,org.reactivestreams.Publisher<In>>
public StreamLayout.AtomicModule withAttributes(Attributes attr)