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>>
,StreamLayout.AtomicModule<SourceShape<T>,TestPublisher.Probe<T>>
- Enclosing class:
- StreamTestKit
public static final class StreamTestKit.ProbeSource<T> extends SourceModule<T,TestPublisher.Probe<T>>
-
-
Constructor Summary
Constructors Constructor Description ProbeSource(Attributes attributes, SourceShape<T> shape, ActorSystem system)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description Attributes
attributes()
scala.Tuple2<TestPublisher.Probe<T>,TestPublisher.Probe<T>>
create(MaterializationContext context)
protected SourceModule<T,TestPublisher.Probe<T>>
newInstance(SourceShape<T> shape)
SourceModule<T,TestPublisher.Probe<T>>
withAttributes(Attributes attr)
-
Methods inherited from class akka.stream.impl.SourceModule
amendShape, label, shape, toString, traversalBuilder
-
-
-
-
Constructor Detail
-
ProbeSource
public ProbeSource(Attributes attributes, SourceShape<T> shape, ActorSystem system)
-
-
Method Detail
-
attributes
public Attributes attributes()
- Specified by:
attributes
in classSourceModule<T,TestPublisher.Probe<T>>
-
create
public scala.Tuple2<TestPublisher.Probe<T>,TestPublisher.Probe<T>> create(MaterializationContext context)
-
newInstance
protected SourceModule<T,TestPublisher.Probe<T>> newInstance(SourceShape<T> shape)
- Specified by:
newInstance
in classSourceModule<T,TestPublisher.Probe<T>>
-
withAttributes
public SourceModule<T,TestPublisher.Probe<T>> withAttributes(Attributes attr)
-
-