Package | Description |
---|---|
org.apache.flink.statefun.sdk.java.testing |
Modifier and Type | Method and Description |
---|---|
static SideEffects.EgressSideEffect |
SideEffects.sentEgress(EgressMessage message) |
Modifier and Type | Method and Description |
---|---|
java.util.List<SideEffects.EgressSideEffect> |
TestContext.getSentEgressMessages()
This method returns a list of all egress messages sent by this function via
Context.send(EgressMessage) . |
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.