akka.stream.impl

Class SubscriberSink<In>

java.lang.Object

akka.stream.impl.StreamLayout.AtomicModule

akka.stream.impl.SinkModule<In,NotUsed>

akka.stream.impl.SubscriberSink<In>

All Implemented Interfaces:

StreamLayout.Module

public final class SubscriberSink<In>
extends SinkModule<In,NotUsed>

INTERNAL API Attaches a subscriber to this stream.

Constructor Summary

Constructors

Constructor and Description
SubscriberSink(org.reactivestreams.Subscriber<In> subscriber, Attributes attributes, SinkShape<In> shape)

Method Summary

Modifier and Type	Method and Description
Attributes	attributes()
scala.Tuple2<org.reactivestreams.Subscriber<In>,NotUsed$>	create(MaterializationContext context)
protected SinkModule<In,NotUsed>	newInstance(SinkShape<In> shape)
StreamLayout.AtomicModule	withAttributes(Attributes attr)

Methods inherited from class akka.stream.impl.SinkModule

amendShape, carbonCopy, label, replaceShape, shape, toString

Methods inherited from class akka.stream.impl.StreamLayout.AtomicModule

downstreams, inPorts, outPorts, subModules, upstreams

Methods inherited from class java.lang.Object

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

Methods inherited from interface akka.stream.impl.StreamLayout.Module

compose, compose, composeNoMat, equals, fuse, fuse, hashCode, isAtomic, isBidiFlow, isCopied, isFlow, isFused, isRunnable, isSealed, isSink, isSource, materializedValueComputation, transformMaterializedValue, wire

Constructor Detail

SubscriberSink

public SubscriberSink(org.reactivestreams.Subscriber<In> subscriber,
                      Attributes attributes,
                      SinkShape<In> shape)

Method Detail

attributes

public Attributes attributes()

create

public scala.Tuple2<org.reactivestreams.Subscriber<In>,NotUsed$> create(MaterializationContext context)

newInstance

protected SinkModule<In,NotUsed> newInstance(SinkShape<In> shape)

Specified by:

newInstance in class SinkModule<In,NotUsed>

withAttributes

public StreamLayout.AtomicModule withAttributes(Attributes attr)