org.apache.flink.statefun.sdk.java.testing

Class SideEffects

java.lang.Object

org.apache.flink.statefun.sdk.java.testing.SideEffects

public final class SideEffects
extends java.lang.Object

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	SideEffects.EgressSideEffect A utility class that wraps a EgressMessage thats was sent by a StatefulFunction.
static class	SideEffects.SendAfterSideEffect A utility class that wraps a Message and the Duration after which it was sent by a StatefulFunction.
static class	SideEffects.SendSideEffect A utility class that wraps a Message that was sent by a StatefulFunction.

Method Summary

Modifier and Type	Method and Description
static SideEffects.SendAfterSideEffect	sentAfter(java.time.Duration duration, Message message)
static SideEffects.EgressSideEffect	sentEgress(EgressMessage message)
static SideEffects.SendSideEffect	sentMessage(Message message)

Methods inherited from class java.lang.Object

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

Method Detail

sentMessage

public static SideEffects.SendSideEffect sentMessage(Message message)

sentAfter

public static SideEffects.SendAfterSideEffect sentAfter(java.time.Duration duration,
                                                        Message message)

sentEgress

public static SideEffects.EgressSideEffect sentEgress(EgressMessage message)