object TestSink

Java API

Source
TestSink.scala
Linear Supertypes
AnyRef, Any
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. TestSink
  2. AnyRef
  3. Any
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. Protected

Value Members

  1. def create[T](system: ClassicActorSystemProvider): Sink[T, Probe[T]]

    A Sink that materialized to a akka.stream.testkit.TestSubscriber.Probe.

Deprecated Value Members

  1. def probe[T](system: ActorSystem): Sink[T, Probe[T]]

    A Sink that materialized to a akka.stream.testkit.TestSubscriber.Probe.

    A Sink that materialized to a akka.stream.testkit.TestSubscriber.Probe.

    Annotations
    @deprecated
    Deprecated

    (Since version 2.7.0) Use TestSink.create with ClassicActorSystemProvider instead.