org.apache.pekko.stream.testkit

Class Utils$

java.lang.Object

org.apache.pekko.stream.testkit.Utils$

public class Utils$
extends java.lang.Object

Field Summary

Fields

Modifier and Type	Field and Description
static Utils$	MODULE$ Static reference to the singleton instance of this Scala object.

Constructor Summary

Constructors

Constructor and Description
Utils$()

Method Summary

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

Field Detail

MODULE$

public static final Utils$ MODULE$

Static reference to the singleton instance of this Scala object.

Constructor Detail

Utils$

public Utils$()

Method Detail

UnboundedMailboxConfig

public com.typesafe.config.Config UnboundedMailboxConfig()

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

assertAllStagesStopped

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

assertDispatcher

public void assertDispatcher(org.apache.pekko.actor.ActorRef ref,
                             java.lang.String dispatcher)