Utils

java.lang.Object

org.apache.pekko.stream.testkit.Utils

public class Utils extends Object

Nested Class Summary

Nested Classes

Modifier and Type

Class

Description

static class

Utils.TE

static class

Utils.TE$
Constructor Summary

Constructors

Constructor

Description

Utils()
Method Summary

Modifier and Type

Method

Description

static <T> T

assertAllStagesStopped(scala.Function0<T> block, org.apache.pekko.stream.Materializer materializer)

static void

assertDispatcher(org.apache.pekko.actor.ActorRef ref, String dispatcher)

static com.typesafe.config.Config

UnboundedMailboxConfig()

Sets the default-mailbox to the usual pekko.dispatch.UnboundedMailbox instead of StreamTestDefaultMailbox.

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details
- Utils
  
  public Utils()
Method Details
- UnboundedMailboxConfig
  
  public static com.typesafe.config.Config UnboundedMailboxConfig()
  
  Sets the default-mailbox to the usual pekko.dispatch.UnboundedMailbox instead of StreamTestDefaultMailbox.
- assertAllStagesStopped
  
  public static <T> T assertAllStagesStopped(scala.Function0<T> block, org.apache.pekko.stream.Materializer materializer)
- assertDispatcher
  
  public static void assertDispatcher(org.apache.pekko.actor.ActorRef ref, String dispatcher)