akka.stream.testkit.scaladsl

Class TestSource

java.lang.Object

akka.stream.testkit.scaladsl.TestSource

public class TestSource
extends java.lang.Object

Factory methods for test sources.

Constructor Summary

Constructors

Constructor and Description
TestSource()

Method Summary

Modifier and Type	Method and Description
static <T> Source<T,TestPublisher.Probe<T>>	probe(ActorSystem system) A Source that materializes to a TestPublisher.Probe.

Methods inherited from class java.lang.Object

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

Constructor Detail

TestSource

public TestSource()

Method Detail

probe

public static <T> Source<T,TestPublisher.Probe<T>> probe(ActorSystem system)

A Source that materializes to a TestPublisher.Probe.

Parameters:

system - (undocumented)

Returns:

(undocumented)