public static final class StreamTestKit.ProbeSink<T> extends SinkModule<T,TestSubscriber.Probe<T>>
Constructor and Description |
---|
ProbeSink(Attributes attributes,
SinkShape<T> shape,
ActorSystem system) |
Modifier and Type | Method and Description |
---|---|
Attributes |
attributes() |
scala.Tuple2<TestSubscriber.Probe<T>,TestSubscriber.Probe<T>> |
create(MaterializationContext context) |
protected SinkModule<T,TestSubscriber.Probe<T>> |
newInstance(SinkShape<T> shape) |
StreamLayout.Module |
withAttributes(Attributes attr) |
amendShape, carbonCopy, label, replaceShape, shape, toString
downstreams, inPorts, outPorts, subModules, upstreams
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
compose, compose, composeNoMat, equals, fuse, fuse, hashCode, isAtomic, isBidiFlow, isCopied, isFlow, isFused, isRunnable, isSealed, isSink, isSource, materializedValueComputation, transformMaterializedValue, wire
public ProbeSink(Attributes attributes, SinkShape<T> shape, ActorSystem system)
public Attributes attributes()
public scala.Tuple2<TestSubscriber.Probe<T>,TestSubscriber.Probe<T>> create(MaterializationContext context)
protected SinkModule<T,TestSubscriber.Probe<T>> newInstance(SinkShape<T> shape)
newInstance
in class SinkModule<T,TestSubscriber.Probe<T>>
public StreamLayout.Module withAttributes(Attributes attr)