Package akka.stream.testkit

Class StreamTestKit.ProbeSource<T>

java.lang.Object

akka.stream.impl.SourceModule<T,TestPublisher.Probe<T>>

akka.stream.testkit.StreamTestKit.ProbeSource<T>

All Implemented Interfaces:

Graph<SourceShape<T>,TestPublisher.Probe<T>>, akka.stream.impl.StreamLayout.AtomicModule<SourceShape<T>,TestPublisher.Probe<T>>

Enclosing class:

StreamTestKit

public static final class StreamTestKit.ProbeSource<T>
extends akka.stream.impl.SourceModule<T,TestPublisher.Probe<T>>

Nested Class Summary

Nested classes/interfaces inherited from interface akka.stream.Graph

Graph.GraphMapMatVal<S extends Shape,M>

Constructor Summary

Constructors

Constructor	Description
ProbeSource(Attributes attributes, SourceShape<T> shape, ActorSystem system)

Method Summary

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

Methods inherited from class akka.stream.impl.SourceModule

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 Detail

ProbeSource

public ProbeSource(Attributes attributes,
                   SourceShape<T> shape,
                   ActorSystem system)

Method Detail

attributes

public Attributes attributes()

Specified by:

attributes in class akka.stream.impl.SourceModule<T,TestPublisher.Probe<T>>

create

public scala.Tuple2<TestPublisher.Probe<T>,TestPublisher.Probe<T>> create(akka.stream.MaterializationContext context)

withAttributes

public akka.stream.impl.SourceModule<T,TestPublisher.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.