Package org.apache.pekko.stream.testkit.scaladsl

Class TestSink

java.lang.Object

org.apache.pekko.stream.testkit.scaladsl.TestSink

public class TestSink
extends java.lang.Object

Factory methods for test sinks.

Constructor Summary

Constructors

Constructor	Description
TestSink()

Method Summary

Modifier and Type	Method	Description
static <T> Sink<T,TestSubscriber.Probe<T>>	apply(ClassicActorSystemProvider system)	A Sink that materialized to a pekko.stream.testkit.TestSubscriber.
static <T> Sink<T,TestSubscriber.Probe<T>>	probe(ActorSystem system)	Deprecated. Use `TestSink.apply` with implicit ClassicActorSystemProvider instead of ActorSystem.

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)

Deprecated.

Use `TestSink.apply` with implicit ClassicActorSystemProvider instead of ActorSystem. Since 1.3.0.

A Sink that materialized to a pekko.stream.testkit.TestSubscriber.

apply

public static <T> Sink<T,TestSubscriber.Probe<T>> apply(ClassicActorSystemProvider system)

A Sink that materialized to a pekko.stream.testkit.TestSubscriber.