org.apache.pekko.stream.testkit

Class Utils

java.lang.Object

org.apache.pekko.stream.testkit.Utils

public class Utils
extends java.lang.Object

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	Utils.TE
static class	Utils.TE$

Constructor Summary

Constructors

Constructor and Description
Utils()

Method Summary

Modifier and Type	Method and Description
static <T> T	assertAllStagesStopped(scala.Function0<T> block, org.apache.pekko.stream.Materializer materializer)
static void	assertDispatcher(org.apache.pekko.actor.ActorRef ref, java.lang.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 Detail

Utils

public Utils()

Method Detail

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,
                                    java.lang.String dispatcher)