Package org.apache.pekko.stream.testkit

Class StreamTestKit.ProbeSink<T>

java.lang.Object

org.apache.pekko.stream.impl.SinkModule<T,TestSubscriber.Probe<T>>

org.apache.pekko.stream.testkit.StreamTestKit.ProbeSink<T>

All Implemented Interfaces:

Graph<SinkShape<T>,TestSubscriber.Probe<T>>, org.apache.pekko.stream.impl.StreamLayout.AtomicModule<SinkShape<T>,TestSubscriber.Probe<T>>

Enclosing class:

StreamTestKit

public static final class StreamTestKit.ProbeSink<T>
extends org.apache.pekko.stream.impl.SinkModule<T,TestSubscriber.Probe<T>>

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.pekko.stream.Graph

Graph.GraphMapMatVal<S extends Shape,M>

Constructor Summary

Constructors

Constructor	Description
ProbeSink(Attributes attributes, SinkShape<T> shape, ActorSystem system)

Method Summary

Modifier and Type	Method	Description
Attributes	attributes()
scala.Tuple2<TestSubscriber.Probe<T>,TestSubscriber.Probe<T>>	create(org.apache.pekko.stream.MaterializationContext context)
org.apache.pekko.stream.impl.SinkModule<T,TestSubscriber.Probe<T>>	withAttributes(Attributes attr)	Replace the attributes of this Flow with the given ones.

Methods inherited from class org.apache.pekko.stream.impl.SinkModule

addAttributes, amendShape, async, async, async, getAttributes, label, named, shape, toString, traversalBuilder

Methods inherited from class java.lang.Object

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

Constructor Details

ProbeSink

public ProbeSink(Attributes attributes,
 SinkShape<T> shape,
 ActorSystem system)

Method Details

attributes

public Attributes attributes()

Specified by:

attributes in class org.apache.pekko.stream.impl.SinkModule<T,TestSubscriber.Probe<T>>

create

public scala.Tuple2<TestSubscriber.Probe<T>,TestSubscriber.Probe<T>> create(org.apache.pekko.stream.MaterializationContext context)

withAttributes

public org.apache.pekko.stream.impl.SinkModule<T,TestSubscriber.Probe<T>> withAttributes(Attributes attr)

Description copied from interface: Graph

Replace the attributes of this Flow with the given ones. If this Flow is a composite of multiple graphs, new attributes on the composite will be less specific than attributes set directly on the individual graphs of the composite.