Package org.apache.pekko.stream.testkit

Class GraphStageMessages

java.lang.Object

org.apache.pekko.stream.testkit.GraphStageMessages

public class GraphStageMessages
extends Object

Messages emitted after the corresponding stageUnderTest methods has been invoked.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	GraphStageMessages.DownstreamFinish$
static class	GraphStageMessages.Failure
static class	GraphStageMessages.Failure$
static class	GraphStageMessages.Pull$
static class	GraphStageMessages.Push$
static class	GraphStageMessages.StageFailure	Sent to the probe when the operator callback threw an exception param: operation The operation that failed
static class	GraphStageMessages.StageFailure$
static interface	GraphStageMessages.StageMessage
static class	GraphStageMessages.UpstreamFinish$

Constructor Summary

Constructors

Constructor	Description
GraphStageMessages()

Method Summary

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

GraphStageMessages

public GraphStageMessages()