akka.stream.testkit.scaladsl

Class TestSink

java.lang.Object

akka.stream.testkit.scaladsl.TestSink

public class TestSink
extends java.lang.Object

Factory methods for test sinks.

Constructor Summary

Constructors

Constructor and Description
TestSink()

Method Summary

Modifier and Type	Method and Description
static <T> Sink<T,TestSubscriber.Probe<T>>	probe(ActorSystem system) A Sink that materialized to a TestSubscriber.Probe.

Methods inherited from class java.lang.Object

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

Constructor Detail

TestSink

public TestSink()

Method Detail

probe

public static <T> Sink<T,TestSubscriber.Probe<T>> probe(ActorSystem system)

A Sink that materialized to a TestSubscriber.Probe.

Parameters:

system - (undocumented)

Returns:

(undocumented)