Class TestSink


  • public class TestSink
    extends java.lang.Object
    Java API
    • Constructor Detail

      • TestSink

        public TestSink()
    • Method Detail

      • probe

        public static <T> Sink<T,​TestSubscriber.Probe<T>> probe​(ActorSystem system)
        Deprecated.
        Use `TestSink.create` with ClassicActorSystemProvider instead of ActorSystem. Since 1.3.0.
        A Sink that materialized to a pekko.stream.testkit.TestSubscriber.