Packages

o

akka.stream.testkit.scaladsl

StreamTestKit

object StreamTestKit

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

Value Members

  1. def assertAllStagesStopped[T](block: ⇒ T)(implicit materializer: Materializer): T

    Asserts that after the given code block is ran, no stages are left over that were created by the given materializer.

    Asserts that after the given code block is ran, no stages are left over that were created by the given materializer.

    This assertion is useful to check that all of the stages have terminated successfully.