akka.stream.testkit

Class StreamTestKit.ProbeSource<T>

java.lang.Object

akka.stream.impl.StreamLayout.AtomicModule

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

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

All Implemented Interfaces:

StreamLayout.Module

Enclosing class:

StreamTestKit

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

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method and Description
Attributes	attributes()
scala.Tuple2<TestPublisher.Probe<T>,TestPublisher.Probe<T>>	create(MaterializationContext context)
protected SourceModule<T,TestPublisher.Probe<T>>	newInstance(SourceShape<T> shape)
StreamLayout.Module	withAttributes(Attributes attr)

Methods inherited from class akka.stream.impl.SourceModule

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

ProbeSource

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

Method Detail

attributes

public Attributes attributes()

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 class SourceModule<T,TestPublisher.Probe<T>>

withAttributes

public StreamLayout.Module withAttributes(Attributes attr)