public final class FanoutPublisherSink<In> extends SinkModule<In,org.reactivestreams.Publisher<In>>
Constructor and Description |
---|
FanoutPublisherSink(Attributes attributes,
SinkShape<In> shape) |
Modifier and Type | Method and Description |
---|---|
Attributes |
attributes() |
scala.Tuple2<org.reactivestreams.Subscriber<In>,org.reactivestreams.Publisher<In>> |
create(MaterializationContext context) |
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 FanoutPublisherSink(Attributes attributes, SinkShape<In> shape)
public Attributes attributes()
public scala.Tuple2<org.reactivestreams.Subscriber<In>,org.reactivestreams.Publisher<In>> create(MaterializationContext context)
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)