PublisherSink

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.

Nested Class Summary
- Nested classes/interfaces inherited from interface akka.stream.Graph
  Graph.GraphMapMatVal<S extends Shape,M>

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)`	Create the Subscriber or VirtualPublisher that consumes the incoming stream, plus the materialized value.
`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)
```
    Description copied from class: SinkModule
    
    Create the Subscriber or VirtualPublisher that consumes the incoming stream, plus the materialized value. Since Subscriber and VirtualPublisher do not share a common supertype apart from AnyRef this is what the type union devolves into; unfortunately we do not have union types at our disposal at this point.
    
    Specified by:
    
    create in class SinkModule<In,org.reactivestreams.Publisher<In>>
  - withAttributes
```
public SinkModule<In,org.reactivestreams.Publisher<In>> withAttributes(Attributes attr)
```