corda / net.corda.testing.flows

Package net.corda.testing.flows

Extensions for External Classes

kotlin.collections.Map

kotlin.reflect.KClass

Functions

from

infix fun <T : Class<out Any>> T.from(session: FlowSession): Pair<FlowSession, T>

Creates a [Pair(session, Class)] from this Class.

receiveAll

fun FlowLogic<*>.receiveAll(session: Pair<FlowSession, Class<out Any>>, vararg sessions: Pair<FlowSession, Class<out Any>>): Map<FlowSession, UntrustworthyData<Any>>
fun <R : Any> FlowLogic<*>.receiveAll(receiveType: Class<R>, session: FlowSession, vararg sessions: FlowSession): List<UntrustworthyData<R>>
fun <R : Any> FlowLogic<*>.receiveAll(session: FlowSession, vararg sessions: FlowSession): List<UntrustworthyData<R>>

Suspends until a message has been received for each session in the specified sessions.

registerCordappFlowFactory

fun <P : FlowLogic<*>> TestStartedNode.registerCordappFlowFactory(initiatingFlowClass: KClass<out FlowLogic<*>>, initiatedFlowVersion: Int = 1, flowFactory: (FlowSession) -> P): CordaFuture<P>

registerCoreFlowFactory

fun <T : FlowLogic<*>> TestStartedNode.registerCoreFlowFactory(initiatingFlowClass: Class<out FlowLogic<*>>, initiatedFlowClass: Class<T>, flowFactory: (FlowSession) -> T, track: Boolean): Observable<T>