public class FlowTestsUtilsKt
Modifier and Type | Method and Description |
---|---|
static <R> R |
from(java.util.Map<net.corda.core.flows.FlowSession,? extends net.corda.core.utilities.UntrustworthyData<? extends java.lang.Object>> $receiver,
FlowSession session)
Extracts data from a [MapFlowSession,UntrustworthyData] without performing checks and casting to R.
|
static <T extends Class<? extends java.lang.Object>> |
from(T $receiver,
FlowSession session)
|
static <T> NonExistentClass |
from(KClass<T> $receiver,
FlowSession session)
|
static java.util.Map<net.corda.core.flows.FlowSession,net.corda.core.utilities.UntrustworthyData> |
receiveAll(FlowLogic<?> $receiver,
NonExistentClass session,
NonExistentClass sessions)
Suspends until a message has been received for each session in the specified sessions.
|
static <R> java.util.List<net.corda.core.utilities.UntrustworthyData> |
receiveAll(FlowLogic<?> $receiver,
java.lang.Class<R> receiveType,
FlowSession session,
net.corda.core.flows.FlowSession sessions)
Suspends until a message has been received for each session in the specified sessions.
|
static <T extends FlowLogic<?>> |
registerCoreFlowFactory(net.corda.testing.node.internal.TestStartedNode $receiver,
java.lang.Class<? extends net.corda.core.flows.FlowLogic<?>> initiatingFlowClass,
java.lang.Class<T> initiatedFlowClass,
Function1<? super net.corda.core.flows.FlowSession,? extends T> flowFactory,
boolean track) |
public static <R> R from(java.util.Map<net.corda.core.flows.FlowSession,? extends net.corda.core.utilities.UntrustworthyData<? extends java.lang.Object>> $receiver, FlowSession session)
Extracts data from a [MapFlowSession,UntrustworthyData] without performing checks and casting to R.
public static <T extends Class<? extends java.lang.Object>> NonExistentClass from(T $receiver, FlowSession session)
public static <T> NonExistentClass from(KClass<T> $receiver, FlowSession session)
public static java.util.Map<net.corda.core.flows.FlowSession,net.corda.core.utilities.UntrustworthyData> receiveAll(FlowLogic<?> $receiver, NonExistentClass session, NonExistentClass sessions)
Suspends until a message has been received for each session in the specified sessions.
Consider receiveAllreceiveTypeClass,sessionsListListUntrustworthyData when the same type is expected from all sessions.
Remember that when receiving data from other parties the data should not be trusted until it's been thoroughly verified for consistency and that all expectations are satisfied, as a malicious peer may send you subtly corrupted data in order to exploit your code.
public static <R> java.util.List<net.corda.core.utilities.UntrustworthyData> receiveAll(FlowLogic<?> $receiver, java.lang.Class<R> receiveType, FlowSession session, net.corda.core.flows.FlowSession sessions)
Suspends until a message has been received for each session in the specified sessions.
Consider sessionsMapFlowSession,ClassMapFlowSession,UntrustworthyData when sessions are expected to receive different types.
Remember that when receiving data from other parties the data should not be trusted until it's been thoroughly verified for consistency and that all expectations are satisfied, as a malicious peer may send you subtly corrupted data in order to exploit your code.
public static <T extends FlowLogic<?>> NonExistentClass registerCoreFlowFactory(net.corda.testing.node.internal.TestStartedNode $receiver, java.lang.Class<? extends net.corda.core.flows.FlowLogic<?>> initiatingFlowClass, java.lang.Class<T> initiatedFlowClass, Function1<? super net.corda.core.flows.FlowSession,? extends T> flowFactory, boolean track)