Class TestSink$


  • public class TestSink$
    extends java.lang.Object
    Factory methods for test sinks.
    • Field Detail

      • MODULE$

        public static final TestSink$ MODULE$
        Static reference to the singleton instance of this Scala object.
    • Constructor Detail

      • TestSink$

        public TestSink$()
    • Method Detail

      • probe

        public <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.